Interface BidiStream<S,R>

All Superinterfaces:

AutoCloseable, BaseStream, ReceiveStream<R>, SendStream<S>

All Known Implementing Classes:

RpcStreamImpl, StreamProxy

public interface BidiStream<S,R>
extends SendStream<S>, ReceiveStream<R>

Method Summary

Modifier and Type	Method	Description
static <Q,R> BidiStream<Q,R>	create(StreamHandler<BidiStream<R,Q>> handler)
void	flush()
R	sendAndGet(S object)

Methods inherited from interface BaseStream

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

Methods inherited from interface ReceiveStream

receive

Methods inherited from interface SendStream

send

Method Details

flush

void flush()
    throws IOException

Throws:

IOException

sendAndGet

R sendAndGet(S object)
      throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

create

static <Q,R> BidiStream<Q,R> create(StreamHandler<BidiStream<R,Q>> handler)