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

Class TripleServerStream

java.lang.Object

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

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

All Implemented Interfaces:

ServerStream, Stream

public class TripleServerStream
extends AbstractStream
implements ServerStream

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	TripleServerStream.ServerTransportObserver

Nested classes/interfaces inherited from interface org.apache.dubbo.rpc.protocol.tri.stream.ServerStream

ServerStream.Listener

Field Summary

Fields

Modifier and Type	Field and Description
TripleServerStream.ServerTransportObserver	transportObserver

Constructor Summary

Constructors

Constructor and Description
TripleServerStream(io.netty.channel.Channel channel, org.apache.dubbo.rpc.model.FrameworkModel frameworkModel, Executor executor, PathResolver pathResolver, String acceptEncoding, List<HeaderFilter> filters)

Method Summary

Modifier and Type	Method and Description
io.netty.util.concurrent.Future<?>	cancelByLocal(TriRpcStatus status) Cancel by this peer.
io.netty.channel.ChannelFuture	complete(TriRpcStatus status, Map<String,Object> attachments) Complete the stream, send response to client
SocketAddress	remoteAddress() Get remote peer address.
void	request(int n) Request n message from remote peer.
io.netty.channel.ChannelFuture	reset(io.netty.handler.codec.http2.Http2Error cause)
io.netty.channel.ChannelFuture	sendHeader(io.netty.handler.codec.http2.Http2Headers headers) Send headers to remote peer.
io.netty.channel.ChannelFuture	sendMessage(byte[] message, int compressFlag) Send message to client

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

transportObserver

public final TripleServerStream.ServerTransportObserver transportObserver

Constructor Detail

TripleServerStream

public TripleServerStream(io.netty.channel.Channel channel,
                          org.apache.dubbo.rpc.model.FrameworkModel frameworkModel,
                          Executor executor,
                          PathResolver pathResolver,
                          String acceptEncoding,
                          List<HeaderFilter> filters)

Method Detail

remoteAddress

public SocketAddress remoteAddress()

Description copied from interface: Stream

Get remote peer address.

Specified by:

remoteAddress in interface Stream

Returns:

socket address of remote peer

request

public void request(int n)

Description copied from interface: Stream

Request n message from remote peer.

Specified by:

request in interface Stream

Parameters:

n - number of message

reset

public io.netty.channel.ChannelFuture reset(io.netty.handler.codec.http2.Http2Error cause)

sendHeader

public io.netty.channel.ChannelFuture sendHeader(io.netty.handler.codec.http2.Http2Headers headers)

Description copied from interface: Stream

Send headers to remote peer.

Specified by:

sendHeader in interface Stream

Parameters:

headers - headers to send to remote peer

Returns:

future to callback when send headers is done

cancelByLocal

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

Description copied from interface: Stream

Cancel by this peer.

Specified by:

cancelByLocal in interface Stream

Parameters:

status - cancel status to send to remote peer

Returns:

future to callback when cancel is done

complete

public io.netty.channel.ChannelFuture complete(TriRpcStatus status,
                                               Map<String,Object> attachments)

Description copied from interface: ServerStream

Complete the stream, send response to client

Specified by:

complete in interface ServerStream

Parameters:

status - response status

attachments - response attachments

Returns:

a future that indicates the completion of send trailers

sendMessage

public io.netty.channel.ChannelFuture sendMessage(byte[] message,
                                                  int compressFlag)

Description copied from interface: ServerStream

Send message to client

Specified by:

sendMessage in interface ServerStream

Parameters:

message - raw message

compressFlag - whether to compress the message

Returns:

a future that indicates the completion of send message