Uses of Interface
java.util.concurrent.Flow.Subscriber

Packages that use Flow.Subscriber

软件包	描述
java.util.concurrent	实用程序类通常用于并发编程。
jdk.incubator.http	高级HTTP和WebSocket API

Uses of Flow.Subscriber in java.util.concurrent

Subinterfaces of Flow.Subscriber in java.util.concurrent

Modifier and Type	接口	描述
static interface	Flow.Processor<T,R>	作为订阅者和发布者的组件。

Methods in java.util.concurrent that return types with arguments of type Flow.Subscriber

Modifier and Type	方法	描述
List<Flow.Subscriber<? super T>>	SubmissionPublisher.getSubscribers()	返回用于监视和跟踪目的的当前用户列表，而不是在订阅者上调用Flow.Subscriber方法。

Methods in java.util.concurrent with parameters of type Flow.Subscriber

Modifier and Type	方法	描述
boolean	SubmissionPublisher.isSubscribed(Flow.Subscriber<? super T> subscriber)	如果给定订阅者当前订阅，则返回true。
void	Flow.Publisher.subscribe(Flow.Subscriber<? super T> subscriber)	如果可能，添加给定的订阅者。
void	SubmissionPublisher.subscribe(Flow.Subscriber<? super T> subscriber)	添加给定订阅者，除非已经订阅。

Method parameters in java.util.concurrent with type arguments of type Flow.Subscriber

Modifier and Type	方法	描述
int	SubmissionPublisher.offer(T item, long timeout, TimeUnit unit, BiPredicate<Flow.Subscriber<? super T>,? super T> onDrop)	如果可能，通过异步调用其 onNext方法来发布给定的项目，阻止当任何订阅的资源不可用时，直到指定的超时或直到调用者线程被中断，此时给定的处理程序-null）被调用，如果返回true，则重试一次。
int	SubmissionPublisher.offer(T item, BiPredicate<Flow.Subscriber<? super T>,? super T> onDrop)	如果可能，通过异步调用其 onNext方法向每个当前用户发布给定项目。

Constructor parameters in java.util.concurrent with type arguments of type Flow.Subscriber

Constructor	描述
SubmissionPublisher(Executor executor, int maxBufferCapacity, BiConsumer<? super Flow.Subscriber<? super T>,? super Throwable> handler)	使用给定的Executor创建一个新的SubmissionPublisher，用于为订户提供异步传递，每个订户具有给定的最大缓冲区大小，如果非空，则在任何订阅者在方法 onNext中引发异常时调用给定处理程序。

Uses of Flow.Subscriber in jdk.incubator.http

Subinterfaces of Flow.Subscriber in jdk.incubator.http

Modifier and Type	接口	描述
static interface	HttpResponse.BodyProcessor<T>	响应机构的处理器。