Package one.nio.rpc.stream
Interface BidiStream<S,R>
-
- All Superinterfaces:
java.lang.AutoCloseable,BaseStream,ReceiveStream<R>,SendStream<S>
- All Known Implementing Classes:
RpcStreamImpl,StreamProxy
public interface BidiStream<S,R> extends SendStream<S>, ReceiveStream<R>
-
-
Method Summary
All Methods Static Methods Instance Methods Abstract Methods Modifier and Type Method Description static <Q,R>
BidiStream<Q,R>create(StreamHandler<BidiStream<R,Q>> handler)voidflush()RsendAndGet(S object)-
Methods inherited from interface one.nio.rpc.stream.BaseStream
close, getBytesRead, getBytesWritten, getLocalAddress, getRemoteAddress, invalidate, socket
-
Methods inherited from interface one.nio.rpc.stream.ReceiveStream
receive
-
Methods inherited from interface one.nio.rpc.stream.SendStream
send
-
-
-
-
Method Detail
-
flush
void flush() throws java.io.IOException- Throws:
java.io.IOException
-
sendAndGet
R sendAndGet(S object) throws java.io.IOException, java.lang.ClassNotFoundException
- Throws:
java.io.IOExceptionjava.lang.ClassNotFoundException
-
create
static <Q,R> BidiStream<Q,R> create(StreamHandler<BidiStream<R,Q>> handler)
-
-