Uses of Interface
org.glassfish.jersey.internal.jsr166.Flow.Subscriber
Packages that use Flow.Subscriber
Package
Description
Contains a subset of classes repackaged from the jsr166 written by Doug Lea.
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.jsr166Modifier and TypeInterfaceDescriptionstatic 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.SubscriberModifier and TypeClassDescriptionprivate static final class
Subscriber for method consumeFields in org.glassfish.jersey.internal.jsr166 declared as Flow.SubscriberModifier and TypeFieldDescription(package private) Flow.Subscriber<? super T>
SubmissionPublisher.BufferedSubscription.subscriber
Fields in org.glassfish.jersey.internal.jsr166 with type parameters of type Flow.SubscriberModifier and TypeFieldDescription(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.SubscriberModifier and TypeMethodDescriptionList<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.SubscriberModifier and TypeMethodDescriptionprivate 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.SubscriberModifier and TypeMethodDescription(package private) final int
SubmissionPublisher.doOffer
(long nanos, T item, BiPredicate<Flow.Subscriber<? super T>, ? super T> onDrop) Common implementation for both forms of offerint
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 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, 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.SubscriberModifierConstructorDescription(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.SubscriberModifierConstructorDescription(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 methodonNext
. -
Uses of Flow.Subscriber in org.glassfish.jersey.internal.util
Classes in org.glassfish.jersey.internal.util that implement Flow.SubscriberFields in org.glassfish.jersey.internal.util declared as Flow.SubscriberModifier and TypeFieldDescriptionprivate Flow.Subscriber<? super T>
JerseyPublisher.SubscriberWrapper.subscriber
Methods in org.glassfish.jersey.internal.util that return Flow.SubscriberModifier and TypeMethodDescriptionFlow.Subscriber<? super T>
JerseyPublisher.SubscriberWrapper.getWrappedSubscriber()
Methods in org.glassfish.jersey.internal.util with parameters of type Flow.SubscriberModifier and TypeMethodDescriptionJerseyPublisher.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.SubscriberModifier and TypeMethodDescriptionprivate 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 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, 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