Package io.servicetalk.http.api

Class AbstractHttpRequesterFilterTest

java.lang.Object

io.servicetalk.http.api.AbstractHttpRequesterFilterTest

public abstract class AbstractHttpRequesterFilterTest
extends java.lang.Object

This parameterized test facilitates running HTTP requester filter tests under all calling variations: client, connection, reserved connection, with and without SSL context.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	AbstractHttpRequesterFilterTest.RequesterType
static interface	AbstractHttpRequesterFilterTest.RequestHandler	Handler for HttpRequester.request(HttpExecutionStrategy, HttpRequest) calls as delegated from the filter under test.
static interface	AbstractHttpRequesterFilterTest.RequestWithContextHandler	Handler for HttpRequester.request(HttpExecutionStrategy, HttpRequest) calls with ConnectionContext information as delegated from the filter under test.
static class	AbstractHttpRequesterFilterTest.SecurityType

Field Summary

Fields

Modifier and Type	Field	Description
org.mockito.junit.MockitoRule	rule
AbstractHttpRequesterFilterTest.SecurityType	security
org.junit.rules.Timeout	timeout
AbstractHttpRequesterFilterTest.RequesterType	type

Constructor Summary

Constructors

Constructor	Description
AbstractHttpRequesterFilterTest(AbstractHttpRequesterFilterTest.RequesterType type, AbstractHttpRequesterFilterTest.SecurityType security)

Method Summary

Modifier and Type	Method	Description
protected BlockingHttpRequester	asBlockingRequester(StreamingHttpRequester requester)
void	closeClients()
protected <FF extends StreamingHttpClientFilterFactory & StreamingHttpConnectionFilterFactory> StreamingHttpRequester	createFilter(FF filterFactory)	Creates filter with default OK request handlers.
protected <FF extends StreamingHttpClientFilterFactory & StreamingHttpConnectionFilterFactory> StreamingHttpRequester	createFilter(AbstractHttpRequesterFilterTest.RequestHandler rh, FF filterFactory)	Creates filter with provided request handler.
protected <FF extends StreamingHttpClientFilterFactory & StreamingHttpConnectionFilterFactory> StreamingHttpRequester	createFilter(AbstractHttpRequesterFilterTest.RequestHandler rh, AbstractHttpRequesterFilterTest.RequestWithContextHandler rwch, FF filterFactory)	Creates filter with provided request handlers.
protected Publisher<java.lang.Object>	loadbalancerEvents()
protected java.net.InetSocketAddress	localAddress()
protected java.net.InetSocketAddress	remoteAddress()
static java.util.Collection<java.lang.Object[]>	requesterTypes()
void	setupContext()
protected javax.net.ssl.SSLSession	sslSession()

Methods inherited from class java.lang.Object

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

Field Detail

rule

public final org.mockito.junit.MockitoRule rule

timeout

public final org.junit.rules.Timeout timeout

type

public final AbstractHttpRequesterFilterTest.RequesterType type

security

public final AbstractHttpRequesterFilterTest.SecurityType security

Constructor Detail

AbstractHttpRequesterFilterTest

public AbstractHttpRequesterFilterTest(AbstractHttpRequesterFilterTest.RequesterType type,
                                       AbstractHttpRequesterFilterTest.SecurityType security)

Method Detail

requesterTypes

public static java.util.Collection<java.lang.Object[]> requesterTypes()

setupContext

public final void setupContext()

remoteAddress

protected java.net.InetSocketAddress remoteAddress()

localAddress

protected java.net.InetSocketAddress localAddress()

sslSession

protected javax.net.ssl.SSLSession sslSession()

loadbalancerEvents

protected Publisher<java.lang.Object> loadbalancerEvents()

closeClients

public final void closeClients()
                        throws java.lang.Exception

Throws:

java.lang.Exception

createFilter

protected final <FF extends StreamingHttpClientFilterFactory & StreamingHttpConnectionFilterFactory> StreamingHttpRequester createFilter(FF filterFactory)

Creates filter with default OK request handlers.

Type Parameters:

FF - type capture for the filter factory

Parameters:

filterFactory - factory used to create the filters

Returns:

a filtered StreamingHttpRequester

createFilter

protected final <FF extends StreamingHttpClientFilterFactory & StreamingHttpConnectionFilterFactory> StreamingHttpRequester createFilter(AbstractHttpRequesterFilterTest.RequestHandler rh,
                                                                                                                                         FF filterFactory)

Creates filter with provided request handler.

Type Parameters:

FF - type capture for the filter factory

Parameters:

rh - handler responding to requests without ConnectionContext

filterFactory - factory used to create the filters

Returns:

a filtered StreamingHttpRequester

createFilter

protected final <FF extends StreamingHttpClientFilterFactory & StreamingHttpConnectionFilterFactory> StreamingHttpRequester createFilter(AbstractHttpRequesterFilterTest.RequestHandler rh,
                                                                                                                                         AbstractHttpRequesterFilterTest.RequestWithContextHandler rwch,
                                                                                                                                         FF filterFactory)

Creates filter with provided request handlers.

Type Parameters:

FF - type capture for the filter factory

Parameters:

rh - handler responding to requests without ConnectionContext

rwch - handler responding to requests with ConnectionContext

filterFactory - factory used to create the filters

Returns:

a filtered StreamingHttpRequester

asBlockingRequester

protected BlockingHttpRequester asBlockingRequester(StreamingHttpRequester requester)