|
FlexDoc/Javadoc 2.0 Demo Java Doc |
|||||||||||||
Packages that use Flow.Subscriber |
|
|
Utility classes commonly useful in concurrent programming.
|
|
Uses of Flow.Subscriber in java.util.concurrent |
Subinterfaces of Flow.Subscriber in java.util.concurrent |
|
static interface |
A component that acts as both a Subscriber and Publisher.
|
Methods in java.util.concurrent that return types with arguments of type Flow.Subscriber |
|
|
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 |
|
void |
Adds the given Subscriber if possible.
|
boolean |
Returns true if the given Subscriber is currently subscribed.
|
void |
Adds the given Subscriber unless already subscribed.
|
Method parameters in java.util.concurrent with type arguments of type Flow.Subscriber |
|
int |
Publishes the given item, if possible, to each current subscriber
by asynchronously invoking its onNext method.
|
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.
|
Constructor parameters in java.util.concurrent with type arguments of type Flow.Subscriber |
|
|
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.
|
|
FlexDoc/Javadoc 2.0 Demo Java Doc |
|||||||||||||