public abstract class AbstractClientHttpRequest extends java.lang.Object implements ClientHttpRequest
ClientHttpRequest
implementations.Constructor and Description |
---|
AbstractClientHttpRequest() |
AbstractClientHttpRequest(HttpHeaders headers) |
Modifier and Type | Method and Description |
---|---|
protected abstract void |
applyCookies()
Add cookies from
getHeaders() to the underlying response. |
protected abstract void |
applyHeaders()
Apply header changes from
getHeaders() to the underlying response. |
void |
beforeCommit(java.util.function.Supplier<? extends reactor.core.publisher.Mono<java.lang.Void>> action)
Register an action to apply just before the HttpOutputMessage is committed.
|
protected reactor.core.publisher.Mono<java.lang.Void> |
doCommit()
A variant of
doCommit(Supplier) for a request without body. |
protected reactor.core.publisher.Mono<java.lang.Void> |
doCommit(java.util.function.Supplier<? extends org.reactivestreams.Publisher<java.lang.Void>> writeAction)
Apply
beforeCommit actions, apply the
request headers/cookies, and write the request body. |
MultiValueMap<java.lang.String,HttpCookie> |
getCookies()
Return a mutable map of request cookies to send to the server.
|
HttpHeaders |
getHeaders()
Return the headers of this message.
|
boolean |
isCommitted()
Whether the HttpOutputMessage is committed.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getMethod, getURI
bufferFactory, setComplete, writeAndFlushWith, writeWith
public AbstractClientHttpRequest()
public AbstractClientHttpRequest(HttpHeaders headers)
public HttpHeaders getHeaders()
HttpMessage
getHeaders
in interface HttpMessage
null
)public MultiValueMap<java.lang.String,HttpCookie> getCookies()
ClientHttpRequest
getCookies
in interface ClientHttpRequest
public void beforeCommit(java.util.function.Supplier<? extends reactor.core.publisher.Mono<java.lang.Void>> action)
ReactiveHttpOutputMessage
Note: the supplied action must be properly deferred,
e.g. via Mono.defer(java.util.function.Supplier<? extends reactor.core.publisher.Mono<? extends T>>)
or Mono.fromRunnable(java.lang.Runnable)
, to ensure it's
executed in the right order, relative to other actions.
beforeCommit
in interface ReactiveHttpOutputMessage
action
- the action to applypublic boolean isCommitted()
ReactiveHttpOutputMessage
isCommitted
in interface ReactiveHttpOutputMessage
protected reactor.core.publisher.Mono<java.lang.Void> doCommit()
doCommit(Supplier)
for a request without body.protected reactor.core.publisher.Mono<java.lang.Void> doCommit(@Nullable java.util.function.Supplier<? extends org.reactivestreams.Publisher<java.lang.Void>> writeAction)
beforeCommit
actions, apply the
request headers/cookies, and write the request body.writeAction
- the action to write the request body (may be null
)protected abstract void applyHeaders()
getHeaders()
to the underlying response.
This method is called once only.protected abstract void applyCookies()
getHeaders()
to the underlying response.
This method is called once only.