org.apache.dubbo.rpc.protocol.tri.command

Class HeaderQueueCommand

java.lang.Object

org.apache.dubbo.rpc.protocol.tri.command.QueuedCommand

org.apache.dubbo.rpc.protocol.tri.command.HeaderQueueCommand

public class HeaderQueueCommand
extends QueuedCommand

Method Summary

Modifier and Type	Method and Description
static HeaderQueueCommand	createHeaders(io.netty.handler.codec.http2.Http2Headers headers)
static HeaderQueueCommand	createHeaders(io.netty.handler.codec.http2.Http2Headers headers, boolean endStream)
void	doSend(io.netty.channel.ChannelHandlerContext ctx, io.netty.channel.ChannelPromise promise)
io.netty.handler.codec.http2.Http2Headers	getHeaders()
boolean	isEndStream()

Methods inherited from class org.apache.dubbo.rpc.protocol.tri.command.QueuedCommand

cancel, promise, promise, run, send

Methods inherited from class java.lang.Object

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

Method Detail

createHeaders

public static HeaderQueueCommand createHeaders(io.netty.handler.codec.http2.Http2Headers headers)

createHeaders

public static HeaderQueueCommand createHeaders(io.netty.handler.codec.http2.Http2Headers headers,
                                               boolean endStream)

getHeaders

public io.netty.handler.codec.http2.Http2Headers getHeaders()

isEndStream

public boolean isEndStream()

doSend

public void doSend(io.netty.channel.ChannelHandlerContext ctx,
                   io.netty.channel.ChannelPromise promise)

Specified by:

doSend in class QueuedCommand