Class ConnectionMetadata (0.6.0)

public class ConnectionMetadata implements AutoCloseable

Inheritance

java.lang.Object > ConnectionMetadata

Implements

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)

Constructors

ConnectionMetadata(InputStream rawInputStream, OutputStream rawOutputStream)

public ConnectionMetadata(InputStream rawInputStream, OutputStream rawOutputStream)

Creates a DataInputStream and a DataOutputStream from the given raw streams and pushes these as the current streams to use for communication for a connection.

Parameters

Name	Description
rawInputStream	`InputStream`
rawOutputStream	`OutputStream`

Methods

close()

public void close()

Exceptions

Type	Description
Exception

peekInputStream()

public DataInputStream peekInputStream()

Returns the current DataInputStream for the connection.

Returns

Type	Description
DataInputStream

peekOutputStream()

public DataOutputStream peekOutputStream()

Returns the current DataOutputStream for the connection.

Returns

Type	Description
DataOutputStream

popStreams()

public Tuple<DataInputStream,DataOutputStream> popStreams()

Pops the current DataInputStream and DataOutputStream from the connection. This is done when the COPY sub-protocol has finished.

Returns

Type	Description
com.google.cloud.Tuple<DataInputStream,DataOutputStream>

pushNewStreams()

public Tuple<DataInputStream,DataOutputStream> pushNewStreams()

Creates a new buffered DataInputStream and DataOutputStream tuple to use for the connection. This is used for the COPY sub-protocol to prevent mixing the buffers used for the normal protocol with the COPY protocol, as that would cause multithreaded access to those buffers.

Returns

Type	Description
com.google.cloud.Tuple<DataInputStream,DataOutputStream>