Searched refs:mSubscriber (Results 1 – 2 of 2) sorted by relevance
75 final Subscriber<? super T> mSubscriber; field in LiveDataReactiveStreams.LiveDataPublisher.LiveDataSubscription89 this.mSubscriber = subscriber; in LiveDataSubscription()101 mSubscriber.onNext(t); in onChanged()128 mSubscriber.onError( in request()215 final AtomicReference<LiveDataSubscriber> mSubscriber; field in LiveDataReactiveStreams.PublisherLiveData219 mSubscriber = new AtomicReference<>(); in PublisherLiveData()226 mSubscriber.set(s); in onActive()233 LiveDataSubscriber s = mSubscriber.getAndSet(null); in onInactive()258 mSubscriber.compareAndSet(this, null); in onError()273 mSubscriber.compareAndSet(this, null); in onComplete()
49 private WeakReference<Object> mSubscriber; field in Subscriber54 mSubscriber = new WeakReference<>(subscriber); in Subscriber()59 Object sub = mSubscriber.get(); in toString()65 return mSubscriber.get(); in getReference()