Package io.grpc.netty
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 byNettyClientStream
and passed to theNettyClientHandler
for processing in the Channel thread.
-
-
Field Summary
Fields Modifier and Type Field Description private boolean
get
private io.netty.handler.codec.http2.Http2Headers
headers
private boolean
shouldBeCountedForInUse
private 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
All Methods Instance Methods Concrete Methods 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 io.grpc.netty.WriteQueue.AbstractQueuedCommand
getLink, promise, promise, run
-
-
-
-
Field Detail
-
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 Detail
-
CreateStreamCommand
CreateStreamCommand(io.netty.handler.codec.http2.Http2Headers headers, NettyClientStream.TransportState stream, boolean shouldBeCountedForInUse, boolean get)
-
-
Method Detail
-
stream
NettyClientStream.TransportState stream()
-
headers
io.netty.handler.codec.http2.Http2Headers headers()
-
shouldBeCountedForInUse
boolean shouldBeCountedForInUse()
-
isGet
boolean isGet()
-
-