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

Class DataQueueCommand

java.lang.Object

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

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

public class DataQueueCommand
extends QueuedCommand

Method Summary

Modifier and Type	Method and Description
static DataQueueCommand	createGrpcCommand(byte[] data, boolean endStream, int compressFlag)
void	doSend(io.netty.channel.ChannelHandlerContext ctx, io.netty.channel.ChannelPromise promise)
byte[]	getData()
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

createGrpcCommand

public static DataQueueCommand createGrpcCommand(byte[] data,
                                                 boolean endStream,
                                                 int compressFlag)

doSend

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

Specified by:

doSend in class QueuedCommand

getData

public byte[] getData()

isEndStream

public boolean isEndStream()