Exception ServerStreamingAttemptException (2.57.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
Name Description
cause Throwable
canResume boolean
seenResponses boolean

Methods

canResume()

public boolean canResume()

If the StreamResumptionStrategy supports resuming after this error.

Returns
Type Description
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
Type Description
boolean