Class ConnectedCommitterImpl (1.10.0)

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.handleInitialResponse(StreamResponseT)

SingleConnection.handleStreamResponse(StreamResponseT)

SingleConnection.initialize(StreamRequestT)

SingleConnection.isCompleted()

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`

handleInitialResponse(StreamingCommitCursorResponse response)

protected void handleInitialResponse(StreamingCommitCursorResponse response)

Parameter

Name	Description
`response`	`StreamingCommitCursorResponse`

Overrides

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

Exceptions

Type	Description
`CheckedApiException`

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`