Uses of Interface java.util.concurrent.Flow.Subscriber

Packages that use Flow.Subscriber
Package	Description
java.util.concurrent	Utility classes commonly useful in concurrent programming.
jdk.incubator.http	High level HTTP and WebSocket API

Uses of Flow.Subscriber in java.util.concurrent

Subinterfaces of Flow.Subscriber in java.util.concurrent
Modifier and Type	Interface	Description
`static interface`	`Flow.Processor<T,R>`	A component that acts as both a Subscriber and Publisher.

Methods in java.util.concurrent that return types with arguments of type Flow.Subscriber
Modifier and Type	Method	Description
`List<Flow.Subscriber<? super T>>`	SubmissionPublisher.`getSubscribers()`	Returns a list of current subscribers for monitoring and tracking purposes, not for invoking `Flow.Subscriber` methods on the subscribers.

Methods in java.util.concurrent with parameters of type Flow.Subscriber
Modifier and Type	Method	Description
`boolean`	SubmissionPublisher.`isSubscribed(Flow.Subscriber<? super T> subscriber)`	Returns true if the given Subscriber is currently subscribed.
`void`	Flow.Publisher.`subscribe(Flow.Subscriber<? super T> subscriber)`	Adds the given Subscriber if possible.
`void`	SubmissionPublisher.`subscribe(Flow.Subscriber<? super T> subscriber)`	Adds the given Subscriber unless already subscribed.

Method parameters in java.util.concurrent with type arguments of type Flow.Subscriber
Modifier and Type	Method	Description
`int`	SubmissionPublisher.`offer(T item, long timeout, TimeUnit unit, BiPredicate<Flow.Subscriber<? super T>,? super T> onDrop)`	Publishes the given item, if possible, to each current subscriber by asynchronously invoking its `onNext` method, blocking while resources for any subscription are unavailable, up to the specified timeout or until the caller thread is interrupted, at which point the given handler (if non-null) is invoked, and if it returns true, retried once.
`int`	SubmissionPublisher.`offer(T item, BiPredicate<Flow.Subscriber<? super T>,? super T> onDrop)`	Publishes the given item, if possible, to each current subscriber by asynchronously invoking its `onNext` method.

Constructor parameters in java.util.concurrent with type arguments of type Flow.Subscriber
Constructor	Description
`SubmissionPublisher(Executor executor, int maxBufferCapacity, BiConsumer<? super Flow.Subscriber<? super T>,? super Throwable> handler)`	Creates a new SubmissionPublisher using the given Executor for async delivery to subscribers, with the given maximum buffer size for each subscriber, and, if non-null, the given handler invoked when any Subscriber throws an exception in method `onNext`.

Uses of Flow.Subscriber in jdk.incubator.http

Subinterfaces of Flow.Subscriber in jdk.incubator.http
Modifier and Type Interface Description

static interface HttpResponse.BodyProcessor<T>
A processor for response bodies.