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 final class	SubmissionPublisher.ConsumerSubscriber<T>	Subscriber for method consume

Fields 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) BiConsumer<? super Flow.Subscriber<? super T>,? super Throwable>	SubmissionPublisher.BufferedSubscription.onNextHandler
(package private) final BiConsumer<? super Flow.Subscriber<? super T>,? super Throwable>	SubmissionPublisher.onNextHandler

Methods in org.glassfish.jersey.internal.jsr166 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 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, 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) final int	SubmissionPublisher.doOffer(long nanos, T item, BiPredicate<Flow.Subscriber<? super T>,? super T> onDrop)	Common implementation for both forms of offer
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.

Constructors in org.glassfish.jersey.internal.jsr166 with parameters of type Flow.Subscriber

Modifier	Constructor	Description
(package private)	BufferedSubscription(Flow.Subscriber<? super T> subscriber, Executor executor, BiConsumer<? super Flow.Subscriber<? super T>,? super Throwable> onNextHandler, int maxBufferCapacity)

Constructor parameters in org.glassfish.jersey.internal.jsr166 with type arguments of type Flow.Subscriber

Modifier	Constructor	Description
(package private)	BufferedSubscription(Flow.Subscriber<? super T> subscriber, Executor executor, BiConsumer<? super Flow.Subscriber<? super T>,? super Throwable> onNextHandler, int maxBufferCapacity)
	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 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, 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.
private int	JerseyPublisher.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.

Constructors in org.glassfish.jersey.internal.util with parameters of type Flow.Subscriber

Modifier	Constructor	Description
	SubscriberWrapper(Flow.Subscriber<? super T> subscriber)