パッケージ org.springframework.http

インターフェース ReactiveHttpOutputMessage

すべてのスーパーインターフェース:
HttpMessage
すべての既知のサブインターフェース:
ClientHttpRequest、ServerHttpResponse、ZeroCopyHttpOutputMessage
すべての既知の実装クラス:
AbstractClientHttpRequest、AbstractListenerServerHttpResponse、AbstractServerHttpResponse、ClientHttpRequestDecorator、HttpHeadResponseDecorator、MockClientHttpRequest、MockServerHttpResponse、ServerHttpResponseDecorator
public interface ReactiveHttpOutputMessage extends HttpMessage
出力を Publisher として受け入れる「リアクティブ」HTTP 出力メッセージ。

通常、クライアント側の HTTP リクエストまたはサーバー側の HTTP レスポンスによって実装されます。

導入:
5.0
作成者:
Arjen Poutsma, Sebastien Deleuze

  • メソッドのサマリー

    修飾子と型
    メソッド
    説明
    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(Publisher<? extends Publisher<? extends DataBuffer>> body)
    Publishers の指定された Publisher を使用して、HttpOutputMessage の本体を基礎となる HTTP レイヤーに書き込み、各 Publisher<DataBuffer> の後にフラッシュします。
    reactor.core.publisher.Mono<VoidSE>
    writeWith(Publisher<? extends DataBuffer> body)
    指定された Publisher を使用して、メッセージの本文を基礎となる HTTP レイヤーに書き込みます。

    インターフェース org.springframework.http.HttpMessage から継承されたメソッド

    getHeaders

  • メソッドの詳細

    • bufferFactory

      DataBufferFactory bufferFactory()
      ボディの作成に使用できる DataBufferFactory を返します。
      戻り値:
      緩衝ファクトリ
      関連事項:

    • beforeCommit

      void beforeCommit(SupplierSE<? extends reactor.core.publisher.Mono<VoidSE>> action)
      HttpOutputMessage がコミットされる直前に適用するアクションを登録します。

      注意 : 指定されたアクションは適切に延期する必要があります。Mono.defer(java.util.function.Supplier<? extends reactor.core.publisher.Mono<? extends T>>) または Mono.fromRunnable(java.lang.Runnable) を介して、他のアクションに対して適切な順序で実行されるようにします。

      パラメーター:
      action - 適用するアクション

    • isCommitted

      boolean isCommitted()
      HttpOutputMessage がコミットされているかどうか。

    • writeWith

      reactor.core.publisher.Mono<VoidSE> writeWith(Publisher<? extends DataBuffer> body)
      指定された Publisher を使用して、メッセージの本文を基礎となる HTTP レイヤーに書き込みます。
      パラメーター:
      body - 本文コンテンツ発行者
      戻り値:
      完了またはエラーを示す Mono 

    • writeAndFlushWith

      reactor.core.publisher.Mono<VoidSE> writeAndFlushWith(Publisher<? extends Publisher<? extends DataBuffer>> body)
      Publishers の指定された Publisher を使用して、HttpOutputMessage の本体を基礎となる HTTP レイヤーに書き込み、各 Publisher<DataBuffer> の後にフラッシュします。
      パラメーター:
      body - 本文コンテンツ発行者
      戻り値:
      完了またはエラーを示す Mono 

    • setComplete

      reactor.core.publisher.Mono<VoidSE> setComplete()
      メッセージ処理が完了したことを示し、クリーンアップまたは処理の終了タスクを実行できるようにします。たとえば、HttpMessage.getHeaders() を介して行われたヘッダー変更を基になる HTTP メッセージに適用します（まだ適用されていない場合）。

      このメソッドは、メッセージ処理の最後に自動的に呼び出される必要があるため、通常はアプリケーションで呼び出す必要はありません。複数回呼び出された場合、副作用はありません。

      戻り値:
      完了またはエラーを示す Mono