org.apache.dubbo.rpc.protocol.tri.stream

Interface Stream

All Known Subinterfaces:

ClientStream, ServerStream

All Known Implementing Classes:

AbstractStream, TripleClientStream, TripleServerStream

public interface Stream

Stream is a bi-directional channel that manipulates the data flow between peers. Inbound data from remote peer is acquired by Stream.Listener. Outbound data to remote peer is sent directly by Stream. Backpressure is supported by request(int).

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static interface	Stream.Listener Register a Stream.Listener to receive inbound data from remote peer.

Method Summary

Modifier and Type	Method and Description
io.netty.util.concurrent.Future<?>	cancelByLocal(TriRpcStatus status) Cancel by this peer.
SocketAddress	remoteAddress() Get remote peer address.
void	request(int n) Request n message from remote peer.
io.netty.util.concurrent.Future<?>	sendHeader(io.netty.handler.codec.http2.Http2Headers headers) Send headers to remote peer.

Method Detail

sendHeader

io.netty.util.concurrent.Future<?> sendHeader(io.netty.handler.codec.http2.Http2Headers headers)

Send headers to remote peer.

Parameters:

headers - headers to send to remote peer

Returns:

future to callback when send headers is done

cancelByLocal

io.netty.util.concurrent.Future<?> cancelByLocal(TriRpcStatus status)

Cancel by this peer.

Parameters:

status - cancel status to send to remote peer

Returns:

future to callback when cancel is done

remoteAddress

SocketAddress remoteAddress()

Get remote peer address.

Returns:

socket address of remote peer

request

void request(int n)

Request n message from remote peer.

Parameters:

n - number of message