Package io.grpc.netty
Class CancelServerStreamCommand
- java.lang.Object
-
- io.grpc.netty.WriteQueue.AbstractQueuedCommand
-
- io.grpc.netty.CancelServerStreamCommand
-
- All Implemented Interfaces:
WriteQueue.QueuedCommand
final class CancelServerStreamCommand extends WriteQueue.AbstractQueuedCommand
Command sent from a Netty server stream to the handler to cancel the stream.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description private static class
CancelServerStreamCommand.PeerNotify
-
Field Summary
Fields Modifier and Type Field Description private CancelServerStreamCommand.PeerNotify
peerNotify
private Status
reason
private NettyServerStream.TransportState
stream
-
Constructor Summary
Constructors Modifier Constructor Description private
CancelServerStreamCommand(NettyServerStream.TransportState stream, Status reason, CancelServerStreamCommand.PeerNotify peerNotify)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description boolean
equals(java.lang.Object o)
int
hashCode()
(package private) Status
reason()
(package private) NettyServerStream.TransportState
stream()
java.lang.String
toString()
(package private) boolean
wantsHeaders()
(package private) static CancelServerStreamCommand
withReason(NettyServerStream.TransportState stream, Status reason)
(package private) static CancelServerStreamCommand
withReset(NettyServerStream.TransportState stream, Status reason)
-
Methods inherited from class io.grpc.netty.WriteQueue.AbstractQueuedCommand
getLink, promise, promise, run
-
-
-
-
Field Detail
-
stream
private final NettyServerStream.TransportState stream
-
reason
private final Status reason
-
peerNotify
private final CancelServerStreamCommand.PeerNotify peerNotify
-
-
Constructor Detail
-
CancelServerStreamCommand
private CancelServerStreamCommand(NettyServerStream.TransportState stream, Status reason, CancelServerStreamCommand.PeerNotify peerNotify)
-
-
Method Detail
-
withReset
static CancelServerStreamCommand withReset(NettyServerStream.TransportState stream, Status reason)
-
withReason
static CancelServerStreamCommand withReason(NettyServerStream.TransportState stream, Status reason)
-
stream
NettyServerStream.TransportState stream()
-
reason
Status reason()
-
wantsHeaders
boolean wantsHeaders()
-
equals
public boolean equals(java.lang.Object o)
- Overrides:
equals
in classjava.lang.Object
-
hashCode
public int hashCode()
- Overrides:
hashCode
in classjava.lang.Object
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
-