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 |