Package io.grpc.netty
Class CreateStreamCommand
java.lang.Object
io.grpc.netty.WriteQueue.AbstractQueuedCommand
io.grpc.netty.CreateStreamCommand
- All Implemented Interfaces:
WriteQueue.QueuedCommand
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
FieldsModifier and TypeFieldDescriptionprivate final boolean
private final io.netty.handler.codec.http2.Http2Headers
private final boolean
private final NettyClientStream.TransportState
-
Constructor Summary
ConstructorsConstructorDescriptionCreateStreamCommand
(io.netty.handler.codec.http2.Http2Headers headers, NettyClientStream.TransportState stream, boolean shouldBeCountedForInUse, boolean get) -
Method Summary
Modifier and TypeMethodDescription(package private) io.netty.handler.codec.http2.Http2Headers
headers()
(package private) boolean
isGet()
(package private) boolean
(package private) NettyClientStream.TransportState
stream()
Methods inherited from class io.grpc.netty.WriteQueue.AbstractQueuedCommand
getLink, promise, promise, run
-
Field Details
-
headers
private final io.netty.handler.codec.http2.Http2Headers headers -
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()
-