public class CachedBodyOutputMessage extends Object implements org.springframework.http.ReactiveHttpOutputMessage
ClientHttpRequest
that saves body as a field.Constructor and Description |
---|
CachedBodyOutputMessage(org.springframework.web.server.ServerWebExchange exchange,
org.springframework.http.HttpHeaders httpHeaders) |
Modifier and Type | Method and Description |
---|---|
void |
beforeCommit(Supplier<? extends reactor.core.publisher.Mono<Void>> action) |
org.springframework.core.io.buffer.DataBufferFactory |
bufferFactory() |
reactor.core.publisher.Flux<org.springframework.core.io.buffer.DataBuffer> |
getBody()
Return the request body, or an error stream if the body was never set or when.
|
org.springframework.http.HttpHeaders |
getHeaders() |
boolean |
isCommitted() |
reactor.core.publisher.Mono<Void> |
setComplete() |
void |
setWriteHandler(Function<reactor.core.publisher.Flux<org.springframework.core.io.buffer.DataBuffer>,reactor.core.publisher.Mono<Void>> writeHandler)
Deprecated.
|
reactor.core.publisher.Mono<Void> |
writeAndFlushWith(org.reactivestreams.Publisher<? extends org.reactivestreams.Publisher<? extends org.springframework.core.io.buffer.DataBuffer>> body) |
reactor.core.publisher.Mono<Void> |
writeWith(org.reactivestreams.Publisher<? extends org.springframework.core.io.buffer.DataBuffer> body) |
public CachedBodyOutputMessage(org.springframework.web.server.ServerWebExchange exchange, org.springframework.http.HttpHeaders httpHeaders)
public void beforeCommit(Supplier<? extends reactor.core.publisher.Mono<Void>> action)
beforeCommit
in interface org.springframework.http.ReactiveHttpOutputMessage
public boolean isCommitted()
isCommitted
in interface org.springframework.http.ReactiveHttpOutputMessage
public org.springframework.http.HttpHeaders getHeaders()
getHeaders
in interface org.springframework.http.HttpMessage
public org.springframework.core.io.buffer.DataBufferFactory bufferFactory()
bufferFactory
in interface org.springframework.http.ReactiveHttpOutputMessage
public reactor.core.publisher.Flux<org.springframework.core.io.buffer.DataBuffer> getBody()
Flux
@Deprecated public void setWriteHandler(Function<reactor.core.publisher.Flux<org.springframework.core.io.buffer.DataBuffer>,reactor.core.publisher.Mono<Void>> writeHandler)
public reactor.core.publisher.Mono<Void> writeWith(org.reactivestreams.Publisher<? extends org.springframework.core.io.buffer.DataBuffer> body)
writeWith
in interface org.springframework.http.ReactiveHttpOutputMessage
public reactor.core.publisher.Mono<Void> writeAndFlushWith(org.reactivestreams.Publisher<? extends org.reactivestreams.Publisher<? extends org.springframework.core.io.buffer.DataBuffer>> body)
writeAndFlushWith
in interface org.springframework.http.ReactiveHttpOutputMessage
public reactor.core.publisher.Mono<Void> setComplete()
setComplete
in interface org.springframework.http.ReactiveHttpOutputMessage
Copyright © 2020 Pivotal Software, Inc.. All rights reserved.