class WiretapClientHttpRequest extends ClientHttpRequestDecorator
Modifier and Type | Field and Description |
---|---|
private <any> |
body |
private DataBuffer |
buffer |
private static DataBufferFactory |
bufferFactory |
Constructor and Description |
---|
WiretapClientHttpRequest(ClientHttpRequest delegate) |
Modifier and Type | Method and Description |
---|---|
<any> |
getRecordedContent()
Return a "promise" with the request body content written to the server.
|
private void |
handleError(java.lang.Throwable ex) |
private void |
handleOnComplete() |
private void |
handleOnNext(DataBuffer buffer) |
<any> |
setComplete()
Indicate that message handling is complete, allowing for any cleanup or
end-of-processing tasks to be performed such as applying header changes
made via
HttpMessage.getHeaders() to the underlying HTTP message (if not
applied already). |
<any> |
writeAndFlushWith(<any> publisher)
Use the given
Publisher of Publishers to write the body
of the HttpOutputMessage to the underlying HTTP layer, flushing after
each Publisher<DataBuffer> . |
<any> |
writeWith(<any> publisher)
Use the given
Publisher to write the body of the message to the
underlying HTTP layer. |
beforeCommit, bufferFactory, getCookies, getDelegate, getHeaders, getMethod, getURI, isCommitted, toString
private static final DataBufferFactory bufferFactory
private final DataBuffer buffer
private final <any> body
public WiretapClientHttpRequest(ClientHttpRequest delegate)
public <any> getRecordedContent()
public <any> writeWith(<any> publisher)
ReactiveHttpOutputMessage
Publisher
to write the body of the message to the
underlying HTTP layer.writeWith
in interface ReactiveHttpOutputMessage
writeWith
in class ClientHttpRequestDecorator
publisher
- the body content publisherMono
that indicates completion or errorpublic <any> writeAndFlushWith(<any> publisher)
ReactiveHttpOutputMessage
Publisher
of Publishers
to write the body
of the HttpOutputMessage to the underlying HTTP layer, flushing after
each Publisher<DataBuffer>
.writeAndFlushWith
in interface ReactiveHttpOutputMessage
writeAndFlushWith
in class ClientHttpRequestDecorator
publisher
- the body content publisherMono
that indicates completion or errorpublic <any> setComplete()
ReactiveHttpOutputMessage
HttpMessage.getHeaders()
to the underlying HTTP message (if not
applied already).
This method should be automatically invoked at the end of message processing so typically applications should not have to invoke it. If invoked multiple times it should have no side effects.
setComplete
in interface ReactiveHttpOutputMessage
setComplete
in class ClientHttpRequestDecorator
Mono
that indicates completion or errorprivate void handleOnNext(DataBuffer buffer)
private void handleError(java.lang.Throwable ex)
private void handleOnComplete()