Searched refs:mEmitter (Results 1 – 1 of 1) sorted by relevance
260 private ObservableEmitter<PagedList<Value>> mEmitter; field in RxPagedListBuilder.PagingObservableOnSubscribe279 mEmitter = emitter; in subscribe()280 mEmitter.setCancellable(this); in subscribe()283 mEmitter.onNext(createPagedList()); in subscribe()296 mEmitter.onNext(createPagedList()); in run()301 if (!mEmitter.isDisposed()) { in onInvalidated()