Class SingleConnection<StreamRequestT,StreamResponseT,ClientResponseT> (1.9.4)

Version 1.9.4

• 1.14.8 (latest)
• 1.14.7
• 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 abstract class SingleConnection<StreamRequestT,StreamResponseT,ClientResponseT> implements ResponseObserver<StreamResponseT>, AutoCloseable

A SingleConnection handles the state for a stream with an initial connection request that may only be sent once and needs to wait for a response before sending other requests.

Inheritance

java.lang.Object > SingleConnection<StreamRequestT,StreamResponseT,ClientResponseT>

Implements

com.google.api.gax.rpc.ResponseObserver<StreamResponseT>, AutoCloseable

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
StreamRequestT
StreamResponseT
ClientResponseT

Static Fields

DEFAULT_STREAM_IDLE_TIMEOUT

protected static final Duration DEFAULT_STREAM_IDLE_TIMEOUT

Field Value

Type	Description
Duration

Constructors

SingleConnection(StreamFactory<StreamRequestT,StreamResponseT> streamFactory, ResponseObserver<ClientResponseT> clientStream)

protected SingleConnection(StreamFactory<StreamRequestT,StreamResponseT> streamFactory, ResponseObserver<ClientResponseT> clientStream)

Parameters

Name	Description
streamFactory	StreamFactory<StreamRequestT,StreamResponseT>
clientStream	ResponseObserver<ClientResponseT>

SingleConnection(StreamFactory<StreamRequestT,StreamResponseT> streamFactory, ResponseObserver<ClientResponseT> clientStream, Duration streamIdleTimeout, boolean expectInitialResponse)

protected SingleConnection(StreamFactory<StreamRequestT,StreamResponseT> streamFactory, ResponseObserver<ClientResponseT> clientStream, Duration streamIdleTimeout, boolean expectInitialResponse)

Parameters

Name	Description
streamFactory	StreamFactory<StreamRequestT,StreamResponseT>
clientStream	ResponseObserver<ClientResponseT>
streamIdleTimeout	Duration
expectInitialResponse	boolean

Methods

close()

public void close()

handleInitialResponse(StreamResponseT response)

protected abstract void handleInitialResponse(StreamResponseT response)

Parameter

Name	Description
response	StreamResponseT

Exceptions

Type	Description
CheckedApiException

handleStreamResponse(StreamResponseT response)

protected abstract void handleStreamResponse(StreamResponseT response)

Parameter

Name	Description
response	StreamResponseT

Exceptions

Type	Description
CheckedApiException

initialize(StreamRequestT initialRequest)

protected void initialize(StreamRequestT initialRequest)

Parameter

Name	Description
initialRequest	StreamRequestT

isCompleted()

protected boolean isCompleted()

Returns

Type	Description
boolean

onComplete()

public void onComplete()

onError(Throwable t)

public void onError(Throwable t)

Parameter

Name	Description
t	Throwable

onResponse(StreamResponseT response)

public void onResponse(StreamResponseT response)

Parameter

Name	Description
response	StreamResponseT

onStart(StreamController streamController)

public void onStart(StreamController streamController)

Parameter

Name	Description
streamController	StreamController

sendToClient(ClientResponseT response)

protected void sendToClient(ClientResponseT response)

Parameter

Name	Description
response	ClientResponseT

sendToStream(StreamRequestT request)

protected void sendToStream(StreamRequestT request)

Parameter

Name	Description
request	StreamRequestT

setError(CheckedApiException error)

protected void setError(CheckedApiException error)

Parameter

Name	Description
error	CheckedApiException