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

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

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

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

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

修飾子と型	インタフェース	説明
static interface	HttpResponse.BodySubscriber<T>	BodySubscriberはレスポンス本文のバイトを消費し、上位のJavaタイプに変換します。

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

修飾子と型	メソッド	説明
static <S extends Flow.Subscriber<? super String>,T> HttpResponse.BodyHandler<T>	HttpResponse.BodyHandlers.fromLineSubscriber(S subscriber, Function<? super S,? extends T> finisher, String lineSeparator)	BodySubscribers.fromLineSubscriber(subscriber, finisher, charset, lineSeparator)から取得したBodySubscriber<T>を返し、指定されたsubscriber、finisher関数および行セパレータを含むレスポンス本文ハンドラを返します。
static <S extends Flow.Subscriber<? super String>,T> HttpResponse.BodySubscriber<T>	HttpResponse.BodySubscribers.fromLineSubscriber(S subscriber, Function<? super S,? extends T> finisher, Charset charset, String lineSeparator)	指定されたFlow.Subscriberの行ごとにすべてのレスポンス本文を転送する本体サブスクライバを返します。
static <S extends Flow.Subscriber<? super List<ByteBuffer>>,T> HttpResponse.BodyHandler<T>	HttpResponse.BodyHandlers.fromSubscriber(S subscriber, Function<? super S,? extends T> finisher)	指定されたsubscriberおよびfinisher関数を使用して、HttpResponse.BodySubscribers.fromSubscriber(Subscriber, Function)から取得されたBodySubscriber<T>を返すレスポンス本文ハンドラを返します。
static <S extends Flow.Subscriber<? super List<ByteBuffer>>,T> HttpResponse.BodySubscriber<T>	HttpResponse.BodySubscribers.fromSubscriber(S subscriber, Function<? super S,? extends T> finisher)	指定されたFlow.Subscriberにすべてのレスポンス本文を転送する本文サブスクライバを返します。

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

修飾子と型	メソッド	説明
static HttpResponse.BodyHandler<Void>	HttpResponse.BodyHandlers.fromLineSubscriber(Flow.Subscriber<? super String> subscriber)	指定されたBodySubscribers.fromLineSubscriber(subscriber, s -> null, charset, null)から取得されたBodySubscriber<Void>を返すレスポンス本文ハンドラを返します。
static HttpResponse.BodySubscriber<Void>	HttpResponse.BodySubscribers.fromLineSubscriber(Flow.Subscriber<? super String> subscriber)	指定されたFlow.Subscriberの行ごとにすべてのレスポンス本文を転送する本体サブスクライバを返します。
static HttpResponse.BodyHandler<Void>	HttpResponse.BodyHandlers.fromSubscriber(Flow.Subscriber<? super List<ByteBuffer>> subscriber)	指定されたHttpResponse.BodySubscribers.fromSubscriber(Subscriber)から取得されたBodySubscriber<Void>を返すレスポンス本文ハンドラを返します。
static HttpResponse.BodySubscriber<Void>	HttpResponse.BodySubscribers.fromSubscriber(Flow.Subscriber<? super List<ByteBuffer>> subscriber)	指定されたFlow.Subscriberにすべてのレスポンス本文を転送する本文サブスクライバを返します。

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

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

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

Flow.Subscriber型の引数を持つ型を返すjava.util.concurrentのメソッド

修飾子と型	メソッド	説明
List<Flow.Subscriber<? super T>>	SubmissionPublisher.getSubscribers()	サブスクライバでFlow.Subscriberメソッドを起動するのではなく、監視および追跡の目的で現在のサブスクライバのリストを返します。

Flow.Subscriber型のパラメータを持つjava.util.concurrentのメソッド

修飾子と型	メソッド	説明
boolean	SubmissionPublisher.isSubscribed(Flow.Subscriber<? super T> subscriber)	指定されたサブスクライバが現在サブスクライブされている場合はtrueを返します。
void	Flow.Publisher.subscribe(Flow.Subscriber<? super T> subscriber)	可能な場合は、指定されたサブスクライバを追加します。
void	SubmissionPublisher.subscribe(Flow.Subscriber<? super T> subscriber)	すでにサブスクライブしていないかぎり、指定されたサブスクライバを追加します。

Flow.Subscriber型の型引数を持つjava.util.concurrentのメソッド・パラメータ

修飾子と型	メソッド	説明
int	SubmissionPublisher.offer(T item, long timeout, TimeUnit unit, BiPredicate<Flow.Subscriber<? super T>,? super T> onDrop)	可能な場合は、onNextメソッドを非同期的に起動し、サブスクリプションのリソースが使用できない間、指定されたタイムアウトまで、または呼出し側スレッドが中断されるまでブロックし、その時点で指定されたハンドラ(null以外の場合)が呼び出され、trueが返された場合は1回再試行することで、指定された項目を現在の各サブスクライバに公開します。
int	SubmissionPublisher.offer(T item, BiPredicate<Flow.Subscriber<? super T>,? super T> onDrop)	可能な場合は、onNextメソッドを非同期に呼び出して、指定された項目を現在の各サブスクライバに公開します。

Flow.Subscriber型の型引数を持つjava.util.concurrentのコンストラクタ・パラメータ

コンストラクタ	説明
SubmissionPublisher(Executor executor, int maxBufferCapacity, BiConsumer<? super Flow.Subscriber<? super T>,? super Throwable> handler)	サブスクライバへの非同期配信用に指定されたエグゼキュータを使用して、各サブスクライバに指定された最大バッファ・サイズで新しいSubmissionPublisherを作成し、null以外の場合は、サブスクライバがメソッドonNextで例外をスローしたときに呼び出される指定されたハンドラを作成します。