io.servicetalk.transport.api

Interface ConnectionContext

All Superinterfaces:

AsyncCloseable, ListenableAsyncCloseable

All Known Subinterfaces:

GrpcServiceContext, HttpConnectionContext, NettyConnection<Read,Write>, NettyConnectionContext, NettyPipelinedConnection<Req,Resp>

All Known Implementing Classes:

DefaultNettyConnection, DefaultNettyPipelinedConnection, DelegatingConnectionContext, DelegatingHttpConnectionContext, DelegatingHttpServiceContext, HttpServiceContext

public interface ConnectionContext
extends ListenableAsyncCloseable

A context for a connection.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static interface	ConnectionContext.Protocol Provides information about the network protocol.

Method Summary

Modifier and Type	Method and Description
ExecutionContext	executionContext() Get the ExecutionContext for this ConnectionContext.
java.net.SocketAddress	localAddress() The SocketAddress to which the associated connection is bound.
ConnectionContext.Protocol	protocol() Get the ConnectionContext.Protocol for this ConnectionContext.
java.net.SocketAddress	remoteAddress() The SocketAddress to which the associated connection is connected.
<T> T	socketOption(java.net.SocketOption<T> option) Get the SocketOption value of type T for this ConnectionContext.
javax.net.ssl.SSLSession	sslSession() Get the SSLSession for this connection.

Methods inherited from interface io.servicetalk.concurrent.api.ListenableAsyncCloseable

onClose

Methods inherited from interface io.servicetalk.concurrent.api.AsyncCloseable

closeAsync, closeAsyncGracefully

Method Detail

localAddress

java.net.SocketAddress localAddress()

The SocketAddress to which the associated connection is bound.

Returns:

The SocketAddress to which the associated connection is bound.

remoteAddress

java.net.SocketAddress remoteAddress()

The SocketAddress to which the associated connection is connected.

Returns:

The SocketAddress to which the associated connection is connected.

sslSession

@Nullable
javax.net.ssl.SSLSession sslSession()

Get the SSLSession for this connection.

Returns:

The SSLSession if SSL/TLS is enabled, or null otherwise.

executionContext

ExecutionContext executionContext()

Get the ExecutionContext for this ConnectionContext.

The ExecutionContext.ioExecutor() will represent the thread responsible for IO for this ConnectionContext. Note that this maybe different that what was used to create this object because at this time a specific IoExecutor has been selected.

Returns:

the ExecutionContext for this ConnectionContext.

socketOption

@Nullable
<T> T socketOption(java.net.SocketOption<T> option)

Get the SocketOption value of type T for this ConnectionContext.

Type Parameters:

T - the type of the SocketOption value.

Parameters:

option - SocketOption to get.

Returns:

the SocketOption value of type T for this ConnectionContext or null if this SocketOption is not supported by this ConnectionContext.

See Also:

StandardSocketOptions, ServiceTalkSocketOptions

protocol

ConnectionContext.Protocol protocol()

Get the ConnectionContext.Protocol for this ConnectionContext.

Returns:

the ConnectionContext.Protocol for this ConnectionContext.