org.springframework.test.web.reactive.server

Class WiretapConnector.WiretapRecorder

java.lang.Object

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

Enclosing class:

WiretapConnector

static final class WiretapConnector.WiretapRecorder
extends java.lang.Object

Tap into a Publisher of data buffers to save the content.

Field Summary

Fields

Modifier and Type	Field and Description
private DataBuffer	buffer
private static DataBufferFactory	bufferFactory
private <any>	content
private boolean	hasContentConsumer
private <any>	publisher
private <any>	publisherNested

Constructor Summary

Constructors

Constructor and Description
WiretapRecorder(<any> publisher, <any> publisherNested)

Method Summary

Modifier and Type	Method and Description
<any>	getContent()
<any>	getNestedPublisherToUse()
<any>	getPublisherToUse()
private void	handleOnComplete()
private void	handleOnError(java.lang.Throwable ex)

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

publisher

@Nullable
private final <any> publisher

publisherNested

@Nullable
private final <any> publisherNested

buffer

private final DataBuffer buffer

content

private final <any> content

hasContentConsumer

private boolean hasContentConsumer

Constructor Detail

WiretapRecorder

public WiretapRecorder(@Nullable
                       <any> publisher,
                       @Nullable
                       <any> publisherNested)

Method Detail

getPublisherToUse

public <any> getPublisherToUse()

getNestedPublisherToUse

public <any> getNestedPublisherToUse()

getContent

public <any> getContent()

handleOnError

private void handleOnError(java.lang.Throwable ex)

handleOnComplete

private void handleOnComplete()