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

Class TripleServerStream.ServerTransportObserver

java.lang.Object

org.apache.dubbo.rpc.protocol.tri.transport.AbstractH2TransportListener

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

All Implemented Interfaces:

H2TransportListener

Enclosing class:

TripleServerStream

public class TripleServerStream.ServerTransportObserver
extends AbstractH2TransportListener
implements H2TransportListener

Constructor Summary

Constructors

Constructor and Description
ServerTransportObserver()

Method Summary

Modifier and Type	Method and Description
void	cancelByRemote(long errorCode)
void	onData(io.netty.buffer.ByteBuf data, boolean endStream) Transport data
void	onHeader(io.netty.handler.codec.http2.Http2Headers headers, boolean endStream) Transport metadata

Methods inherited from class java.lang.Object

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

Constructor Detail

ServerTransportObserver

public ServerTransportObserver()

Method Detail

onHeader

public void onHeader(io.netty.handler.codec.http2.Http2Headers headers,
                     boolean endStream)

Description copied from interface: H2TransportListener

Transport metadata

Specified by:

onHeader in interface H2TransportListener

Parameters:

headers - metadata KV paris

endStream - whether this data should terminate the stream

onData

public void onData(io.netty.buffer.ByteBuf data,
                   boolean endStream)

Description copied from interface: H2TransportListener

Transport data

Specified by:

onData in interface H2TransportListener

Parameters:

data - raw byte array

endStream - whether this data should terminate the stream

cancelByRemote

public void cancelByRemote(long errorCode)

Specified by:

cancelByRemote in interface H2TransportListener