Class ConnectedCommitterImpl (1.12.22)

Version 1.12.22

• 1.14.7 (latest)
• 1.14.4
• 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