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

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

パッケージ	説明
java.util.concurrent	並行プログラミングでよく使用されるユーティリティ・クラスです。
jdk.incubator.http	高レベルのHTTPとWebSocket API

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メソッドを非同期に呼び出し、任意のサブスクリプションのリソースが使用できないとき、指定されたタイムアウトまで、または呼び出し元スレッドが中断されるまで、指定されたアイテムを可能な場合は、各現在のサブスクライバにパブリッシュします。trueを返した場合は、一度再試行します。
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)	各サブスクライバに対して指定された最大バッファ・サイズでサブスクライバへの非同期配信用に、指定されたExecutorを使用して新しいSubmissionPublisherを作成し、ヌル以外の場合、サブスクライバがonNextメソッドで例外をスローしたときに呼び出されます。

jdk.incubator.httpでのFlow.Subscriberの使用

jdk.incubator.httpのFlow.Subscriberのサブインタフェース

修飾子と型	インタフェース	説明
static interface	HttpResponse.BodySubscriber<T>	レスポンス主体のサブスクライバ。

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

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

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

修飾子と型	メソッド	説明
static HttpResponse.BodyHandler<Void>	HttpResponse.BodyHandler. fromSubscriber(Flow.Subscriber<? super List<ByteBuffer>> subscriber)	HttpResponse.BodySubscriber.fromSubscriber(Subscriber)から取得したBodySubscriber <Void>を、指定されたsubscriberを返して返すレスポンス本文ハンドラを返します。