Searched refs:subscriber (Results 1 – 12 of 12) sorted by relevance
53 Subscriber(Object subscriber, long registrationTime) { in Subscriber() argument54 mSubscriber = new WeakReference<>(subscriber); in Subscriber()74 Subscriber subscriber; field in EventHandler77 EventHandler(Subscriber subscriber, EventHandlerMethod method, int priority) { in EventHandler() argument78 this.subscriber = subscriber; in EventHandler()85 return subscriber.toString(priority) + " " + method.toString(); in toString()374 return Long.compare(h2.subscriber.registrationTime, h1.subscriber.registrationTime);449 public void register(Object subscriber) { in register() argument450 registerSubscriber(subscriber, DEFAULT_SUBSCRIBER_PRIORITY, null); in register()462 public void register(Object subscriber, int priority) { in register() argument[all …]
363 TestSubscriber<Integer> subscriber = new TestSubscriber<>(); in publisherCountUsers() local364 mUserDao.publisherCountUsers().subscribe(subscriber); in publisherCountUsers()366 subscriber.assertSubscribed(); in publisherCountUsers()367 subscriber.request(2); in publisherCountUsers()369 subscriber.assertValue(0); in publisherCountUsers()372 subscriber.assertValues(0, 1); in publisherCountUsers()373 subscriber.cancel(); in publisherCountUsers()374 subscriber.assertNoErrors(); in publisherCountUsers()379 final TestSubscriber<UserAndAllPets> subscriber = new TestSubscriber<>(); in flowableWithRelation() local381 mUserPetDao.flowableUserWithPets(3).subscribe(subscriber); in flowableWithRelation()[all …]
57 TestSubscriber<User> subscriber = mDatabase.getUserDao().flowableUserById(3).test(); in testFlowableInTransaction() local58 subscriber.assertValueCount(0); in testFlowableInTransaction()69 subscriber.assertValueCount(1); in testFlowableInTransaction()
144 TestSubscriber<List<Entity1>> subscriber = observe(flowable); in flowable() local146 assertThat(subscriber.values().size(), is(1)); in flowable()152 List<Entity1> allEntities = subscriber.values().get(1); in flowable()265 TestSubscriber<T> subscriber = new TestSubscriber<>(); in observe() local267 .subscribeWith(subscriber); in observe()268 return subscriber; in observe()
70 public void subscribe(Subscriber<? super T> subscriber) { in subscribe() argument71 subscriber.onSubscribe(new LiveDataSubscription<T>(subscriber, mLifecycle, mLiveData)); in subscribe()87 LiveDataSubscription(final Subscriber<? super T> subscriber, in LiveDataSubscription() argument89 this.mSubscriber = subscriber; in LiveDataSubscription()
127 val subscriber = TestSubscriber<Optional<Book>>() in bookByIdOptionalFlowable() constant131 .subscribeWith(subscriber) in bookByIdOptionalFlowable()133 assertThat(subscriber.values().size, `is`(1)) in bookByIdOptionalFlowable()134 assertThat(subscriber.values()[0], `is`(Optional.of(TestUtil.BOOK_1))) in bookByIdOptionalFlowable()139 val subscriber = TestSubscriber<Optional<Book>>() in bookByIdOptionalFlowableAbsent() constant143 .subscribeWith(subscriber) in bookByIdOptionalFlowableAbsent()145 assertThat(subscriber.values().size, `is`(1)) in bookByIdOptionalFlowableAbsent()146 assertThat(subscriber.values()[0], `is`(Optional.absent())) in bookByIdOptionalFlowableAbsent()
164 TestSubscriber<String> subscriber = new TestSubscriber<>(); in exception() local165 flowable.subscribe(subscriber); in exception()167 assertThat(subscriber.errorCount(), CoreMatchers.is(1)); in exception()168 assertThat(subscriber.errors().get(0).getMessage(), CoreMatchers.is("i want exception")); in exception()
74 void factoryReset(String subscriber); in factoryReset() argument
253 public void factoryReset(String subscriber) { in factoryReset() argument255 mService.factoryReset(subscriber); in factoryReset()
67 src/subscriber/IncidentdReporter.cpp \68 src/subscriber/SubscriberReporter.cpp \
4754 public void factoryReset(String subscriber) { in factoryReset() argument4763 NetworkTemplate template = NetworkTemplate.buildTemplateMobileAll(subscriber); in factoryReset()
META-INF/ META-INF/MANIFEST.MF android/ android/databinding/ android/ ...