Package org.apache.dubbo.remoting.http12.netty4.h2

Class NettyH2StreamChannel

java.lang.Object

org.apache.dubbo.remoting.http12.netty4.h2.NettyH2StreamChannel

All Implemented Interfaces:

H2StreamChannel, HttpChannel

public class NettyH2StreamChannel
extends Object
implements H2StreamChannel

Constructor Summary

Constructors

Constructor	Description
NettyH2StreamChannel(io.netty.handler.codec.http2.Http2StreamChannel http2StreamChannel, TripleConfig tripleConfig)

Method Summary

Modifier and Type	Method	Description
void	flush()
SocketAddress	localAddress()
Http2OutputMessage	newOutputMessage(boolean endStream)
SocketAddress	remoteAddress()
CompletableFuture<Void>	writeHeader(HttpMetadata httpMetadata)
CompletableFuture<Void>	writeMessage(HttpOutputMessage httpOutputMessage)
CompletableFuture<Void>	writeResetFrame(long errorCode)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.dubbo.remoting.http12.h2.H2StreamChannel

newOutputMessage

Constructor Details

NettyH2StreamChannel

public NettyH2StreamChannel(io.netty.handler.codec.http2.Http2StreamChannel http2StreamChannel,
 TripleConfig tripleConfig)

Method Details

writeHeader

public CompletableFuture<Void> writeHeader(HttpMetadata httpMetadata)

Specified by:

writeHeader in interface HttpChannel

writeMessage

public CompletableFuture<Void> writeMessage(HttpOutputMessage httpOutputMessage)

Specified by:

writeMessage in interface HttpChannel

newOutputMessage

public Http2OutputMessage newOutputMessage(boolean endStream)

Specified by:

newOutputMessage in interface H2StreamChannel

remoteAddress

public SocketAddress remoteAddress()

Specified by:

remoteAddress in interface HttpChannel

localAddress

public SocketAddress localAddress()

Specified by:

localAddress in interface HttpChannel

flush

public void flush()

Specified by:

flush in interface HttpChannel

writeResetFrame

public CompletableFuture<Void> writeResetFrame(long errorCode)

Specified by:

writeResetFrame in interface H2StreamChannel