Class SingleConnection<StreamRequestT,StreamResponseT,ClientResponseT> (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 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)

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

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

Methods

close()

public void close()

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

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 synchronized void sendToStream(StreamRequestT request)

Parameter
Name	Description
request	StreamRequestT

setError(CheckedApiException error)

protected void setError(CheckedApiException error)

Parameter
Name	Description
error	CheckedApiException