Class CreateStreamCommand

java.lang.Object

io.grpc.netty.WriteQueue.AbstractQueuedCommand

io.grpc.netty.CreateStreamCommand

All Implemented Interfaces:

WriteQueue.QueuedCommand

class CreateStreamCommand
extends WriteQueue.AbstractQueuedCommand

A command to create a new stream. This is created by NettyClientStream and passed to the NettyClientHandler for processing in the Channel thread.

Field Summary

Fields

Modifier and Type	Field	Description
private final boolean	get
private final io.netty.handler.codec.http2.Http2Headers	headers
private final boolean	shouldBeCountedForInUse
private final NettyClientStream.TransportState	stream

Constructor Summary

Constructors

Constructor	Description
CreateStreamCommand(io.netty.handler.codec.http2.Http2Headers headers, NettyClientStream.TransportState stream, boolean shouldBeCountedForInUse, boolean get)

Method Summary

Modifier and Type	Method	Description
(package private) io.netty.handler.codec.http2.Http2Headers	headers()
(package private) boolean	isGet()
(package private) boolean	shouldBeCountedForInUse()
(package private) NettyClientStream.TransportState	stream()

Methods inherited from class WriteQueue.AbstractQueuedCommand

getLink, promise, promise, run

Methods inherited from class Object

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

Field Details

headers

private final io.netty.handler.codec.http2.Http2Headers headers

stream

private final NettyClientStream.TransportState stream

shouldBeCountedForInUse

private final boolean shouldBeCountedForInUse

get

private final boolean get

Constructor Details

CreateStreamCommand

CreateStreamCommand(io.netty.handler.codec.http2.Http2Headers headers,
 NettyClientStream.TransportState stream,
 boolean shouldBeCountedForInUse,
 boolean get)

Method Details

stream

NettyClientStream.TransportState stream()

headers

io.netty.handler.codec.http2.Http2Headers headers()

shouldBeCountedForInUse

boolean shouldBeCountedForInUse()

isGet

boolean isGet()