Home
last modified time | relevance | path

Searched refs:Subscriber (Results 1 – 4 of 4) sorted by relevance

/libcore/ojluni/src/main/java/java/util/concurrent/
DSubmissionPublisher.java49 import static java.util.concurrent.Flow.Subscriber;
251 final BiConsumer<? super Subscriber<? super T>, ? super Throwable> onNextHandler;
275 … BiConsumer<? super Subscriber<? super T>, ? super Throwable> handler) { in SubmissionPublisher()
342 public void subscribe(Subscriber<? super T> subscriber) { in subscribe()
397 BiPredicate<Subscriber<? super T>, ? super T> onDrop) { in doOffer()
448 BiPredicate<Subscriber<? super T>, ? super T> onDrop, in retryOffer()
561 BiPredicate<Subscriber<? super T>, ? super T> onDrop) { in offer()
609 BiPredicate<Subscriber<? super T>, ? super T> onDrop) { in offer()
773 public List<Subscriber<? super T>> getSubscribers() { in getSubscribers()
774 ArrayList<Subscriber<? super T>> subs = new ArrayList<>(); in getSubscribers()
[all …]
DFlow.java208 public void subscribe(Subscriber<? super T> subscriber); in subscribe()
218 public static interface Subscriber<T> { interface in Flow
301 public static interface Processor<T,R> extends Subscriber<T>, Publisher<R> {
/libcore/ojluni/src/test/java/util/concurrent/tck/
DSubmissionPublisherTest.java47 import static java.util.concurrent.Flow.Subscriber;
68 class TestSubscriber implements Subscriber<Integer> {
686 static boolean reqHandle(AtomicInteger count, Subscriber s) { in reqHandle()
1018 class Sub implements Subscriber<Boolean> {
/libcore/api/
Dcurrent.txt15948 …public static interface Flow.Processor<T, R> extends java.util.concurrent.Flow.Subscriber<T> java.…
15952 method public void subscribe(java.util.concurrent.Flow.Subscriber<? super T>);
15955 public static interface Flow.Subscriber<T> {
16314 …, int, java.util.function.BiConsumer<? super java.util.concurrent.Flow.Subscriber<? super T>,? sup…
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 …ent.TimeUnit, java.util.function.BiPredicate<java.util.concurrent.Flow.Subscriber<? super T>,? sup…
16333 method public void subscribe(java.util.concurrent.Flow.Subscriber<? super T>);