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.

Uses of Flow.Subscriber in java.util.concurrent

Subinterfaces of Flow.Subscriber in java.util.concurrent

Modifier and Type	Interface and 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 and 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 and 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 and 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 and 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.