Package io.servicetalk.http.api

Class TestHttpServiceContext

java.lang.Object

io.servicetalk.http.api.HttpServiceContext

io.servicetalk.http.api.TestHttpServiceContext

All Implemented Interfaces:

AsyncCloseable, ListenableAsyncCloseable, HttpConnectionContext, ConnectionContext, ConnectionInfo

public class TestHttpServiceContext
extends HttpServiceContext

Nested Class Summary

Nested classes/interfaces inherited from interface io.servicetalk.transport.api.ConnectionInfo

ConnectionInfo.Protocol

Constructor Summary

Constructors

Constructor	Description
TestHttpServiceContext(HttpHeadersFactory headersFactory, StreamingHttpRequestResponseFactory reqRespFactory, HttpExecutionContext executionContext)

Method Summary

Modifier and Type	Method	Description
BlockingStreamingHttpResponseFactory	blockingStreamingResponseFactory()	Returns the BlockingStreamingHttpResponseFactory associated with this HttpServiceContext.
Completable	closeAsync()	Used to close/shutdown a resource.
HttpExecutionContext	executionContext()	Get the ExecutionContext for this ConnectionInfo.
HttpHeadersFactory	headersFactory()	Returns the HttpHeadersFactory associated with this HttpServiceContext.
java.net.SocketAddress	localAddress()	The SocketAddress to which the associated connection is bound.
Completable	onClose()	Returns a Completable that is notified once the ListenableAsyncCloseable was closed.
HttpProtocolVersion	protocol()	Get the ConnectionInfo.Protocol for this ConnectionInfo.
java.net.SocketAddress	remoteAddress()	The SocketAddress to which the associated connection is connected.
HttpResponseFactory	responseFactory()	Returns the HttpResponseFactory associated with this HttpServiceContext.
<T> T	socketOption(java.net.SocketOption<T> option)	Get the SocketOption value of type T for this ConnectionInfo.
javax.net.ssl.SSLSession	sslSession()	Get the SSLSession for this connection.
StreamingHttpResponseFactory	streamingResponseFactory()	Returns the StreamingHttpResponseFactory associated with this HttpServiceContext.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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

closeAsyncGracefully

Constructor Detail

TestHttpServiceContext

public TestHttpServiceContext(HttpHeadersFactory headersFactory,
                              StreamingHttpRequestResponseFactory reqRespFactory,
                              HttpExecutionContext executionContext)

Method Detail

headersFactory

public HttpHeadersFactory headersFactory()

Description copied from class: HttpServiceContext

Returns the HttpHeadersFactory associated with this HttpServiceContext.

Overrides:

headersFactory in class HttpServiceContext

Returns:

HttpHeadersFactory associated with this HttpServiceContext.

responseFactory

public HttpResponseFactory responseFactory()

Description copied from class: HttpServiceContext

Returns the HttpResponseFactory associated with this HttpServiceContext.

Overrides:

responseFactory in class HttpServiceContext

Returns:

HttpResponseFactory associated with this HttpServiceContext.

streamingResponseFactory

public StreamingHttpResponseFactory streamingResponseFactory()

Description copied from class: HttpServiceContext

Returns the StreamingHttpResponseFactory associated with this HttpServiceContext.

Overrides:

streamingResponseFactory in class HttpServiceContext

Returns:

StreamingHttpResponseFactory associated with this HttpServiceContext.

blockingStreamingResponseFactory

public BlockingStreamingHttpResponseFactory blockingStreamingResponseFactory()

Description copied from class: HttpServiceContext

Returns the BlockingStreamingHttpResponseFactory associated with this HttpServiceContext.

Overrides:

blockingStreamingResponseFactory in class HttpServiceContext

Returns:

BlockingStreamingHttpResponseFactory associated with this HttpServiceContext.

localAddress

public java.net.SocketAddress localAddress()

Description copied from interface: ConnectionInfo

The SocketAddress to which the associated connection is bound.

Returns:

The SocketAddress to which the associated connection is bound.

remoteAddress

public java.net.SocketAddress remoteAddress()

Description copied from interface: ConnectionInfo

The SocketAddress to which the associated connection is connected.

Returns:

The SocketAddress to which the associated connection is connected.

sslSession

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

Description copied from interface: ConnectionInfo

Get the SSLSession for this connection.

Returns:

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

executionContext

public HttpExecutionContext executionContext()

Description copied from interface: ConnectionInfo

Get the ExecutionContext for this ConnectionInfo.

The ExecutionContext.ioExecutor() will represent the thread responsible for IO for this ConnectionInfo. 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 ConnectionInfo.

socketOption

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

Description copied from interface: ConnectionInfo

Get the SocketOption value of type T for this ConnectionInfo.

Type Parameters:

T - the type of the SocketOption value.

Parameters:

option - SocketOption to get.

Returns:

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

See Also:

StandardSocketOptions, ServiceTalkSocketOptions

protocol

public HttpProtocolVersion protocol()

Description copied from interface: ConnectionInfo

Get the ConnectionInfo.Protocol for this ConnectionInfo.

Returns:

the ConnectionInfo.Protocol for this ConnectionInfo.

onClose

public Completable onClose()

Description copied from interface: ListenableAsyncCloseable

Returns a Completable that is notified once the ListenableAsyncCloseable was closed.

Returns:

the Completable that is notified on close.

closeAsync

public Completable closeAsync()

Description copied from interface: AsyncCloseable

Used to close/shutdown a resource.

Returns:

A Completable that is notified once the close is complete.