Lines Matching refs:Flow

15944   public final class Flow {
15948 …public static interface Flow.Processor<T, R> extends java.util.concurrent.Flow.Subscriber<T> java.…
15951   @java.lang.FunctionalInterface public static interface Flow.Publisher<T> {
15952     method public void subscribe(java.util.concurrent.Flow.Subscriber<? super T>);
15955   public static interface Flow.Subscriber<T> {
15959     method public void onSubscribe(java.util.concurrent.Flow.Subscription);
15962   public static interface Flow.Subscription {
16313 …public class SubmissionPublisher<T> implements java.lang.AutoCloseable java.util.concurrent.Flow.P…
16314 …Executor, int, java.util.function.BiConsumer<? super java.util.concurrent.Flow.Subscriber<? super …
16326     method public java.util.List<java.util.concurrent.Flow.Subscriber<? super T>> getSubscribers();
16329     method public boolean isSubscribed(java.util.concurrent.Flow.Subscriber<? super T>);
16330 …method public int offer(T, java.util.function.BiPredicate<java.util.concurrent.Flow.Subscriber<? s…
16331 ….concurrent.TimeUnit, java.util.function.BiPredicate<java.util.concurrent.Flow.Subscriber<? super …
16333     method public void subscribe(java.util.concurrent.Flow.Subscriber<? super T>);