Package one.nio.rpc.stream

Interface ReceiveStream<R>

All Superinterfaces:

java.lang.AutoCloseable, BaseStream

All Known Subinterfaces:

BidiStream<S,R>

All Known Implementing Classes:

RpcStreamImpl, StreamProxy

public interface ReceiveStream<R>
extends BaseStream

Method Summary

Modifier and Type	Method	Description
static <R> ReceiveStream<R>	create(StreamHandler<SendStream<R>> handler)
R	receive()

Methods inherited from interface one.nio.rpc.stream.BaseStream

close, getBytesRead, getBytesWritten, getLocalAddress, getRemoteAddress, invalidate, socket

Method Detail

receive

R receive()
   throws java.io.IOException,
          java.lang.ClassNotFoundException

Throws:

java.io.IOException

java.lang.ClassNotFoundException

create

static <R> ReceiveStream<R> create(StreamHandler<SendStream<R>> handler)