Class ConnectedCommitterImpl (1.16.5)

1.16.5 (latest) 1.16.2 1.15.21 1.14.8 1.13.8 1.12.22 1.11.2 1.10.0 1.9.4 1.8.0 1.7.1 1.6.3 1.5.5 1.4.12

public class ConnectedCommitterImpl extends SingleConnection<StreamingCommitCursorRequest,StreamingCommitCursorResponse,SequencedCommitCursorResponse> implements ConnectedCommitter

Inheritance

java.lang.Object > SingleConnection > ConnectedCommitterImpl

Implements

com.google.cloud.pubsublite.internal.wire.ConnectedCommitter

Inherited Members

SingleConnection.close()

SingleConnection.handleStreamResponse(StreamResponseT)

SingleConnection.initialize(StreamRequestT)

SingleConnection.onComplete()

SingleConnection.onError(Throwable)

SingleConnection.onResponse(StreamResponseT)

SingleConnection.onStart(StreamController)

SingleConnection.sendToClient(ClientResponseT)

SingleConnection.sendToStream(StreamRequestT)

SingleConnection.setError(CheckedApiException)

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)

Methods

commit(Offset offset)

public void commit(Offset offset)

Parameter
Name	Description
offset	Offset

handleStreamResponse(StreamingCommitCursorResponse response)

protected void handleStreamResponse(StreamingCommitCursorResponse response)

Parameter
Name	Description
response	StreamingCommitCursorResponse

Overrides

SingleConnection<StreamRequestT,StreamResponseT,ClientResponseT>.handleStreamResponse(StreamResponseT response)

Exceptions
Type	Description
CheckedApiException