Exception ServerStreamingAttemptException (2.20.0)

public class ServerStreamingAttemptException extends RuntimeException

A wrapper exception thrown by ServerStreamingAttemptCallable to communicate additional context to the StreamingRetryAlgorithm and to pass the original cancellation stack trace to RetryingServerStreamingCallable.

For internal use only - public for technical reasons.

Constructors

ServerStreamingAttemptException(Throwable cause, boolean canResume, boolean seenResponses)

public ServerStreamingAttemptException(Throwable cause, boolean canResume, boolean seenResponses)
Parameters
NameDescription
causeThrowable
canResumeboolean
seenResponsesboolean

Methods

canResume()

public boolean canResume()

If the StreamResumptionStrategy supports resuming after this error.

Returns
TypeDescription
boolean

hasSeenResponses()

public boolean hasSeenResponses()

If the current RPC attempt has seen any streamed messages. This is used as a signal by StreamingRetryAlgorithm to reset timers.

Returns
TypeDescription
boolean