Searched refs:Subscriber (Results 1 – 4 of 4) sorted by relevance
24 import org.reactivestreams.Subscriber;70 public void subscribe(Subscriber<? super T> subscriber) { in subscribe()75 final Subscriber<? super T> mSubscriber;87 LiveDataSubscription(final Subscriber<? super T> subscriber, in LiveDataSubscription()240 implements Subscriber<T> {
48 class Subscriber { class53 Subscriber(Object subscriber, long registrationTime) { in Subscriber() method in Subscriber74 Subscriber subscriber;77 EventHandler(Subscriber subscriber, EventHandlerMethod method, int priority) { in EventHandler()413 private ArrayList<Subscriber> mSubscribers = new ArrayList<>();732 Subscriber sub = new Subscriber(subscriber, SystemClock.uptimeMillis()); in registerSubscriber()929 Subscriber sub = mSubscribers.get(i); in findRegisteredSubscriber()
31 import org.reactivestreams.Subscriber;278 .subscribe(new Subscriber<String>() { in convertsToPublisherWithBackpressure()
53 // [Optional] Prefix of IMSI (International Mobile Subscriber Identity) in