インタフェースjava.util.concurrent.Flow.Publisherの
使用

Flow.Publisherを使用するパッケージ

パッケージ	説明
java.net.http	HTTPクライアントおよびWebSocket API
java.util.concurrent	並行プログラミングでよく使用されるユーティリティ・クラスです。

java.net.httpでのFlow.Publisherの使用

java.net.httpのFlow.Publisherのサブインタフェース

修飾子と型	インタフェース	説明
static interface	HttpRequest.BodyPublisher	BodyPublisherは、上位レベルのJavaオブジェクトをリクエスト本文として送信するのに適したバイト・バッファのフローに変換します。

型Flow.Publisherの引数を持つ型を返すjava.net.httpのメソッド

修飾子と型	メソッド	説明
static HttpResponse.BodyHandler<Flow.Publisher<List<ByteBuffer>>>	HttpResponse.BodyHandlers.ofPublisher()	BodySubscribers.ofPublisher()から取得したBodySubscriber<Publisher<List<ByteBuffer>>>を作成するBodyHandler<Publisher<List<ByteBuffer>>>を返します。
static HttpResponse.BodySubscriber<Flow.Publisher<List<ByteBuffer>>>	HttpResponse.BodySubscribers.ofPublisher()	Publisher<List<ByteBuffer>>を介してレスポンス本文をパブリッシュするレスポンス・サブスクライバを返します。

型Flow.Publisherのパラメータを持つjava.net.httpのメソッド

修飾子と型	メソッド	説明
static HttpRequest.BodyPublisher	HttpRequest.BodyPublishers.fromPublisher(Flow.Publisher<? extends ByteBuffer> publisher)	指定されたFlow.Publisherから本文が取得されたリクエスト・ボディ・パブリッシャを返します。
static HttpRequest.BodyPublisher	HttpRequest.BodyPublishers.fromPublisher(Flow.Publisher<? extends ByteBuffer> publisher, long contentLength)	指定されたFlow.Publisherから本文が取得されたリクエスト・ボディ・パブリッシャを返します。

java.util.concurrentでのFlow.Publisherの使用

java.util.concurrentのFlow.Publisherのサブインタフェース

修飾子と型	インタフェース	説明
static interface	Flow.Processor<T,R>	サブスクライバとパブリッシャの両方として機能するコンポーネント。

Flow.Publisherを実装しているjava.util.concurrentのクラス

修飾子と型	クラス	説明
class	SubmissionPublisher<T>	(non-null)アイテムを非同期で発行するFlow.Publisherは、現在のサブスクライバが閉じられるまでそれを発行します。