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.
jdk.incubator.http	High level HTTP and WebSocket API

Uses of Flow.Subscriber in java.util.concurrent

Subinterfaces of Flow.Subscriber in java.util.concurrent

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

Uses of Flow.Subscriber in jdk.incubator.http

Subinterfaces of Flow.Subscriber in jdk.incubator.http

Modifier and Type	Interface	Description
static interface	HttpResponse.BodySubscriber<T>	A subscriber for response bodies.

Methods in jdk.incubator.http with type parameters of type Flow.Subscriber

Modifier and Type	Method	Description
static <S extends Flow.Subscriber<? super List<ByteBuffer>>,T> HttpResponse.BodyHandler<T>	HttpResponse.BodyHandler.fromSubscriber(S subscriber, Function<S,T> finisher)	Returns a response body handler that returns a BodySubscriber<T> obtained from HttpResponse.BodySubscriber.fromSubscriber(Subscriber, Function), with the given subscriber and finisher function.
static <S extends Flow.Subscriber<? super List<ByteBuffer>>> HttpResponse.BodySubscriber<Void>	HttpResponse.BodySubscriber.fromSubscriber(S subscriber)	Returns a body subscriber that forwards all response body to the given Flow.Subscriber.
static <S extends Flow.Subscriber<? super List<ByteBuffer>>,T> HttpResponse.BodySubscriber<T>	HttpResponse.BodySubscriber.fromSubscriber(S subscriber, Function<S,T> finisher)	Returns a body subscriber that forwards all response body to the given Flow.Subscriber.

Methods in jdk.incubator.http with parameters of type Flow.Subscriber

Modifier and Type	Method	Description
static HttpResponse.BodyHandler<Void>	HttpResponse.BodyHandler.fromSubscriber(Flow.Subscriber<? super List<ByteBuffer>> subscriber)	Returns a response body handler that returns a BodySubscriber<Void> obtained from HttpResponse.BodySubscriber.fromSubscriber(Subscriber), with the given subscriber.