Uses of Interface
org.glassfish.jersey.internal.jsr166.Flow.Subscriber
-
Packages that use Flow.Subscriber Package Description org.glassfish.jersey.internal.jsr166 Contains a subset of classes repackaged from the jsr166 written by Doug Lea.org.glassfish.jersey.internal.util Common Jersey internal miscellaneous utility classes. -
-
Uses of Flow.Subscriber in org.glassfish.jersey.internal.jsr166
Subinterfaces of Flow.Subscriber in org.glassfish.jersey.internal.jsr166 Modifier and Type Interface Description static interface
Flow.Processor<T,R>
A component that acts as both a Subscriber and Publisher.Classes in org.glassfish.jersey.internal.jsr166 that implement Flow.Subscriber Modifier and Type Class Description private static class
SubmissionPublisher.ConsumerSubscriber<T>
Subscriber for method consumeFields in org.glassfish.jersey.internal.jsr166 declared as Flow.Subscriber Modifier and Type Field Description (package private) Flow.Subscriber<? super T>
SubmissionPublisher.BufferedSubscription. subscriber
Fields in org.glassfish.jersey.internal.jsr166 with type parameters of type Flow.Subscriber Modifier and Type Field Description (package private) java.util.function.BiConsumer<? super Flow.Subscriber<? super T>,? super java.lang.Throwable>
SubmissionPublisher.BufferedSubscription. onNextHandler
(package private) java.util.function.BiConsumer<? super Flow.Subscriber<? super T>,? super java.lang.Throwable>
SubmissionPublisher. onNextHandler
Methods in org.glassfish.jersey.internal.jsr166 that return types with arguments of type Flow.Subscriber Modifier and Type Method Description java.util.List<Flow.Subscriber<? super T>>
SubmissionPublisher. getSubscribers()
Returns a list of current subscribers for monitoring and tracking purposes, not for invokingFlow.Subscriber
methods on the subscribers.Methods in org.glassfish.jersey.internal.jsr166 with parameters of type Flow.Subscriber Modifier and Type Method Description private boolean
SubmissionPublisher.BufferedSubscription. checkControl(Flow.Subscriber<? super T> s, int c)
Responds to control events in consume().private boolean
SubmissionPublisher.BufferedSubscription. checkEmpty(Flow.Subscriber<? super T> s, int c)
Responds to apparent emptiness in consume().private void
SubmissionPublisher.BufferedSubscription. handleOnNext(Flow.Subscriber<? super T> s, java.lang.Throwable ex)
Processes exception in Subscriber.onNext.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 org.glassfish.jersey.internal.jsr166 with type arguments of type Flow.Subscriber Modifier and Type Method Description (package private) int
SubmissionPublisher. doOffer(long nanos, T item, java.util.function.BiPredicate<Flow.Subscriber<? super T>,? super T> onDrop)
Common implementation for both forms of offerint
SubmissionPublisher. offer(T item, long timeout, java.util.concurrent.TimeUnit unit, java.util.function.BiPredicate<Flow.Subscriber<? super T>,? super T> onDrop)
Publishes the given item, if possible, to each current subscriber by asynchronously invoking itsonNext
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, java.util.function.BiPredicate<Flow.Subscriber<? super T>,? super T> onDrop)
Publishes the given item, if possible, to each current subscriber by asynchronously invoking itsonNext
method.Constructors in org.glassfish.jersey.internal.jsr166 with parameters of type Flow.Subscriber Constructor Description BufferedSubscription(Flow.Subscriber<? super T> subscriber, java.util.concurrent.Executor executor, java.util.function.BiConsumer<? super Flow.Subscriber<? super T>,? super java.lang.Throwable> onNextHandler, int maxBufferCapacity)
Constructor parameters in org.glassfish.jersey.internal.jsr166 with type arguments of type Flow.Subscriber Constructor Description BufferedSubscription(Flow.Subscriber<? super T> subscriber, java.util.concurrent.Executor executor, java.util.function.BiConsumer<? super Flow.Subscriber<? super T>,? super java.lang.Throwable> onNextHandler, int maxBufferCapacity)
SubmissionPublisher(java.util.concurrent.Executor executor, int maxBufferCapacity, java.util.function.BiConsumer<? super Flow.Subscriber<? super T>,? super java.lang.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 methodonNext
. -
Uses of Flow.Subscriber in org.glassfish.jersey.internal.util
Classes in org.glassfish.jersey.internal.util that implement Flow.Subscriber Modifier and Type Class Description static class
JerseyPublisher.SubscriberWrapper<T>
Fields in org.glassfish.jersey.internal.util declared as Flow.Subscriber Modifier and Type Field Description private Flow.Subscriber<? super T>
JerseyPublisher.SubscriberWrapper. subscriber
Methods in org.glassfish.jersey.internal.util that return Flow.Subscriber Modifier and Type Method Description Flow.Subscriber<? super T>
JerseyPublisher.SubscriberWrapper. getWrappedSubscriber()
Methods in org.glassfish.jersey.internal.util with parameters of type Flow.Subscriber Modifier and Type Method Description private JerseyPublisher.SubscriberWrapper
JerseyPublisher. getSubscriberWrapper(Flow.Subscriber subscriber)
private boolean
JerseyPublisher. onDrop(Flow.Subscriber<? super T> subscriber, T t)
void
JerseyPublisher. subscribe(Flow.Subscriber<? super T> subscriber)
Method parameters in org.glassfish.jersey.internal.util with type arguments of type Flow.Subscriber Modifier and Type Method Description private int
JerseyPublisher. offer(T item, long timeout, java.util.concurrent.TimeUnit unit, java.util.function.BiPredicate<Flow.Subscriber<? super T>,? super T> onDrop)
Publishes the given item, if possible, to each current subscriber by asynchronously invoking itsonNext
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.private int
JerseyPublisher. offer(T item, java.util.function.BiPredicate<Flow.Subscriber<? super T>,? super T> onDrop)
Publishes the given item, if possible, to each current subscriber by asynchronously invoking itsonNext
method.Constructors in org.glassfish.jersey.internal.util with parameters of type Flow.Subscriber Constructor Description SubscriberWrapper(Flow.Subscriber<? super T> subscriber)
-