org.springframework.test.web.reactive.server

Class WiretapConnector

java.lang.Object

org.springframework.test.web.reactive.server.WiretapConnector

All Implemented Interfaces:

ClientHttpConnector

class WiretapConnector
extends java.lang.Object
implements ClientHttpConnector

Decorate another ClientHttpConnector with the purpose of intercepting, capturing, and exposing actual request and response data transmitted to and received from the server.

Since:

5.0

Author:

Rossen Stoyanchev

See Also:

HttpHandlerConnector

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
(package private) class	WiretapConnector.Info
private static class	WiretapConnector.WiretapClientHttpRequest ClientHttpRequestDecorator that intercepts and saves the request body.
private static class	WiretapConnector.WiretapClientHttpResponse ClientHttpResponseDecorator that intercepts and saves the response body.

Field Summary

Fields

Modifier and Type	Field and Description
private static DataBufferFactory	bufferFactory
private ClientHttpConnector	delegate
private java.util.Map<java.lang.String,WiretapConnector.Info>	exchanges

Constructor Summary

Constructors

Constructor and Description
WiretapConnector(ClientHttpConnector delegate)

Method Summary

Modifier and Type	Method and Description
WiretapConnector.Info	claimRequest(java.lang.String requestId) Retrieve the WiretapConnector.Info for the given "request-id" header value.
<any>	connect(HttpMethod method, java.net.URI uri, java.util.function.Function<? super ClientHttpRequest,<any>> requestCallback) Connect to the origin server using the given HttpMethod and URI, then apply the given requestCallback on the ClientHttpRequest once the connection has been established.

Methods inherited from class java.lang.Object

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

Field Detail

bufferFactory

private static final DataBufferFactory bufferFactory

delegate

private final ClientHttpConnector delegate

exchanges

private final java.util.Map<java.lang.String,WiretapConnector.Info> exchanges

Constructor Detail

WiretapConnector

WiretapConnector(ClientHttpConnector delegate)

Method Detail

connect

public <any> connect(HttpMethod method,
                     java.net.URI uri,
                     java.util.function.Function<? super ClientHttpRequest,<any>> requestCallback)

Description copied from interface: ClientHttpConnector

Connect to the origin server using the given HttpMethod and URI, then apply the given requestCallback on the ClientHttpRequest once the connection has been established.

Return a publisher of the ClientHttpResponse.

Specified by:

connect in interface ClientHttpConnector

Parameters:

method - the HTTP request method

uri - the HTTP request URI

requestCallback - a function that prepares and writes the request, returning a publisher that signals when it's done interacting with the request. Implementations should return a Mono<Void> by calling ReactiveHttpOutputMessage.writeWith(<any>) or ReactiveHttpOutputMessage.setComplete().

Returns:

a publisher of the ClientHttpResponse

claimRequest

public WiretapConnector.Info claimRequest(java.lang.String requestId)

Retrieve the WiretapConnector.Info for the given "request-id" header value.