public interface ReactiveHttpOutputMessage extends HttpMessage
Publisher
として受け入れる「リアクティブ」HTTP 出力メッセージ。通常、クライアント側の HTTP リクエストまたはサーバー側の HTTP レスポンスによって実装されます。
修飾子と型 | メソッドと説明 |
---|---|
void | beforeCommit(SupplierSE<? extends reactor.core.publisher.Mono<VoidSE>> action) HttpOutputMessage がコミットされる直前に適用するアクションを登録します。 |
DataBufferFactory | bufferFactory() ボディの作成に使用できる DataBufferFactory を返します。 |
boolean | isCommitted() HttpOutputMessage がコミットされているかどうか。 |
reactor.core.publisher.Mono<VoidSE> | setComplete() メッセージ処理が完了したことを示し、クリーンアップまたは処理の終了タスクを実行できるようにします。たとえば、 HttpMessage.getHeaders() を介して行われたヘッダー変更を基になる HTTP メッセージに適用します(まだ適用されていない場合)。 |
reactor.core.publisher.Mono<VoidSE> | writeAndFlushWith(org.reactivestreams.Publisher<? extends org.reactivestreams.Publisher<? extends DataBuffer>> body) Publishers の指定された Publisher を使用して、HttpOutputMessage の本体を基礎となる HTTP レイヤーに書き込み、各 Publisher<DataBuffer> の後にフラッシュします。 |
reactor.core.publisher.Mono<VoidSE> | writeWith(org.reactivestreams.Publisher<? extends DataBuffer> body) 指定された Publisher を使用して、メッセージの本文を基礎となる HTTP レイヤーに書き込みます。 |
getHeaders
DataBufferFactory bufferFactory()
DataBufferFactory
を返します。writeWith(Publisher)
void beforeCommit(SupplierSE<? extends reactor.core.publisher.Mono<VoidSE>> action)
注意 : 指定されたアクションは適切に延期する必要があります。Mono.defer(java.util.function.Supplier<? extends reactor.core.publisher.Mono<? extends T>>)
または Mono.fromRunnable(java.lang.Runnable)
を介して、他のアクションに対して適切な順序で実行されるようにします。
action
- 適用するアクション boolean isCommitted()
reactor.core.publisher.Mono<VoidSE> writeWith(org.reactivestreams.Publisher<? extends DataBuffer> body)
Publisher
を使用して、メッセージの本文を基礎となる HTTP レイヤーに書き込みます。body
- 本文コンテンツ発行者 Mono
reactor.core.publisher.Mono<VoidSE> writeAndFlushWith(org.reactivestreams.Publisher<? extends org.reactivestreams.Publisher<? extends DataBuffer>> body)
Publishers
の指定された Publisher
を使用して、HttpOutputMessage の本体を基礎となる HTTP レイヤーに書き込み、各 Publisher<DataBuffer>
の後にフラッシュします。body
- 本文コンテンツ発行者 Mono
reactor.core.publisher.Mono<VoidSE> setComplete()
HttpMessage.getHeaders()
を介して行われたヘッダー変更を基になる HTTP メッセージに適用します(まだ適用されていない場合)。このメソッドは、メッセージ処理の最後に自動的に呼び出される必要があるため、通常はアプリケーションで呼び出す必要はありません。複数回呼び出された場合、副作用はありません。
Mono