Class DelayedClientTransport.PendingStream

java.lang.Object

io.grpc.internal.DelayedStream

io.grpc.internal.DelayedClientTransport.PendingStream

All Implemented Interfaces:

ClientStream, Stream

Enclosing class:

DelayedClientTransport

private class DelayedClientTransport.PendingStream
extends DelayedStream

Field Summary

Fields

Modifier and Type	Field	Description
private final LoadBalancer.PickSubchannelArgs	args
private final Context	context
private final ClientStreamTracer[]	tracers

Constructor Summary

Constructors

Modifier	Constructor	Description
private	PendingStream(LoadBalancer.PickSubchannelArgs args, ClientStreamTracer[] tracers)

Method Summary

Modifier and Type	Method	Description
void	appendTimeoutInsight(InsightBuilder insight)	Append information that will be included in the locally generated DEADLINE_EXCEEDED errors to the given InsightBuilder, in order to tell the user about the state of the stream so that they can better diagnose the cause of the error.
void	cancel(Status reason)	Abnormally terminates the stream.
private Runnable	createRealStream(ClientTransport transport)	Runnable may be null.
protected void	onEarlyCancellation(Status reason)

Methods inherited from class DelayedStream

flush, getAttributes, getRealStream, halfClose, isReady, optimizeForDirectExecutor, request, setAuthority, setCompressor, setDeadline, setDecompressorRegistry, setFullStreamDecompression, setMaxInboundMessageSize, setMaxOutboundMessageSize, setMessageCompression, setStream, start, writeMessage

Methods inherited from class Object

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

Field Details

args

private final LoadBalancer.PickSubchannelArgs args

context

private final Context context

tracers

private final ClientStreamTracer[] tracers

Constructor Details

PendingStream

private PendingStream(LoadBalancer.PickSubchannelArgs args,
 ClientStreamTracer[] tracers)

Method Details

createRealStream

private Runnable createRealStream(ClientTransport transport)

Runnable may be null.

cancel

public void cancel(Status reason)

Description copied from interface: ClientStream

Abnormally terminates the stream. After calling this method, no further messages will be sent or received, however it may still be possible to receive buffered messages for a brief period until ClientStreamListener.closed(Status, ClientStreamListener.RpcProgress, Metadata) is called. This method may only be called after ClientStream.start(ClientStreamListener), but else is safe to be called at any time and multiple times and from any thread.

Specified by:

cancel in interface ClientStream

Overrides:

cancel in class DelayedStream

Parameters:

reason - must be non-OK

onEarlyCancellation

protected void onEarlyCancellation(Status reason)

Overrides:

onEarlyCancellation in class DelayedStream

appendTimeoutInsight

public void appendTimeoutInsight(InsightBuilder insight)

Description copied from interface: ClientStream

Append information that will be included in the locally generated DEADLINE_EXCEEDED errors to the given InsightBuilder, in order to tell the user about the state of the stream so that they can better diagnose the cause of the error.

Specified by:

appendTimeoutInsight in interface ClientStream

Overrides:

appendTimeoutInsight in class DelayedStream