Searched refs:subscriber (Results 1 – 2 of 2) sorted by relevance
342 public void subscribe(Subscriber<? super T> subscriber) { in subscribe() argument343 if (subscriber == null) throw new NullPointerException(); in subscribe()349 new BufferedSubscription<T>(subscriber, executor, onNextHandler, in subscribe()379 else if (subscriber.equals(b.subscriber)) { in subscribe()457 if (stat == 0 && onDrop != null && onDrop.test(r.subscriber, item)) in retryOffer()789 subs.add(b.subscriber); in getSubscribers()806 public boolean isSubscribed(Subscriber<? super T> subscriber) { in isSubscribed() argument807 if (subscriber == null) throw new NullPointerException(); in isSubscribed()823 else if (subscribed = subscriber.equals(b.subscriber)) in isSubscribed()1059 final Subscriber<? super T> subscriber; field in SubmissionPublisher.BufferedSubscription[all …]
208 public void subscribe(Subscriber<? super T> subscriber); in subscribe() argument