Class SimpleStreamResumptionStrategy<RequestT,ResponseT> (2.20.1)

Version 2.20.1

• 2.59.0 (latest)
• 2.58.0
• 2.57.0
• 2.55.0
• 2.54.1
• 2.53.0
• 2.52.0
• 2.51.0
• 2.50.0
• 2.49.0
• 2.48.1
• 2.47.0
• 2.46.1
• 2.45.0
• 2.43.0
• 2.42.0
• 2.41.0
• 2.39.0
• 2.38.0
• 2.37.0
• 2.36.0
• 2.35.0
• 2.34.1
• 2.33.0
• 2.32.1
• 2.31.1
• 2.30.1
• 2.24.0
• 2.23.3
• 2.22.0
• 2.21.0
• 2.20.1
• 2.19.6
• 2.18.7
• 2.17.0
• 2.16.0
• 2.15.0
• 2.14.0
• 2.13.0
• 2.12.2
• 2.11.0
• 2.10.0
• 2.9.0
• 2.8.1
• 2.7.1

public final class SimpleStreamResumptionStrategy<RequestT,ResponseT> implements StreamResumptionStrategy<RequestT,ResponseT>

Simplest implementation of a StreamResumptionStrategy which returns the initial request for unstarted streams.

Inheritance

java.lang.Object > SimpleStreamResumptionStrategy<RequestT,ResponseT>

Implements

StreamResumptionStrategy<RequestT,ResponseT>

Inherited Members

Object.clone()

Object.equals(Object)

Object.finalize()

Object.getClass()

Object.hashCode()

Object.notify()

Object.notifyAll()

Object.toString()

Object.wait()

Object.wait(long)

Object.wait(long,int)

Type Parameters

Name	Description
RequestT
ResponseT

Constructors

SimpleStreamResumptionStrategy()

public SimpleStreamResumptionStrategy()

Methods

canResume()

public boolean canResume()

If a resume request can be created.

Returns

Type	Description
boolean

createNew()

public StreamResumptionStrategy<RequestT,ResponseT> createNew()

Creates a new instance of this StreamResumptionStrategy without accumulated state

Returns

Type	Description
StreamResumptionStrategy<RequestT,ResponseT>

getResumeRequest(RequestT originalRequest)

public RequestT getResumeRequest(RequestT originalRequest)

Called when a stream needs to be restarted, the implementation should generate a request that will yield a new stream whose first response would come right after the last response received by processResponse.

Parameter

Name	Description
originalRequest	RequestT

Returns

Type	Description
RequestT

processResponse(ResponseT response)

public ResponseT processResponse(ResponseT response)

Called by the ServerStreamingAttemptCallable when a response has been successfully received. This method accomplishes two goals:

1. It allows the strategy implementation to update its internal state so that it can compose the resume request
2. It allows the strategy to alter the incoming responses to adjust for after resume. For example, if the responses are numbered sequentially from the start of the stream, upon resume, the strategy could rewrite the messages to continue the sequence from where it left off. Please note that all messages (even for the first attempt) will be passed through this method.

Parameter

Name	Description
response	ResponseT

Returns

Type	Description
ResponseT