@Test public void testChildEvents_DataReference_remove() { TestObserver<ChildEvent> sub = TestObserver.create(); RxFirebaseDatabase.childEvents(mockDatabaseReference) .subscribe(sub); verifyDataReferenceAddChildEventListener(); callOnChildRemoved(); callOnChildRemoved(); sub.assertNotComplete(); sub.assertNoErrors(); sub.assertValueCount(2); List events = sub.getEvents().get(0); for (Object event : events) { assertThat(event) .isInstanceOf(ChildRemoveEvent.class); } sub.dispose(); callOnChildRemoved(); sub.assertValueCount(2); }
@NonNull @CheckReturnValue public static Observable<ChildEvent> childEvents(@NonNull final Query query) { return Observable.create(new QueryChildEventsOnSubscribe(query)); }
RxFirebaseDatabase { @NonNull @CheckReturnValue public static Observable<ChildEvent> childEvents(@NonNull final Query query) { return Observable.create(new QueryChildEventsOnSubscribe(query)); } }
RxFirebaseDatabase { @NonNull @CheckReturnValue public static Observable<ChildEvent> childEvents(@NonNull final Query query) { return Observable.create(new QueryChildEventsOnSubscribe(query)); } private  RxFirebaseDatabase(); }
RxFirebaseDatabase { @NonNull @CheckReturnValue public static Observable<ChildEvent> childEvents(@NonNull final Query query) { return Observable.create(new QueryChildEventsOnSubscribe(query)); } private  RxFirebaseDatabase(); @NonNull @CheckReturnValue static Observable<ChildEvent> childEvents(@NonNull final Query query); @NonNull @CheckReturnValue static Single<DataSnapshot> data(@NonNull final Query query); @NonNull @CheckReturnValue static Observable<DataSnapshot> dataChanges(@NonNull final Query query); @NonNull @CheckReturnValue static Observable<DataValue<T>> dataChangesOf(
            @NonNull final DatabaseReference ref, @NonNull final Class<T> clazz); @NonNull @CheckReturnValue static Observable<DataValue<T>> dataChangesOf(
            @NonNull final Query query, @NonNull final Class<T> clazz); @NonNull @CheckReturnValue static Observable<DataValue<T>> dataChangesOf(
            @NonNull DatabaseReference ref, @NonNull GenericTypeIndicator<T> typeIndicator); @NonNull @CheckReturnValue static Observable<DataValue<T>> dataChangesOf(
            @NonNull Query query, @NonNull GenericTypeIndicator<T> typeIndicator); @NonNull @CheckReturnValue static Single<T> dataOf(
            @NonNull DatabaseReference ref, @NonNull Class<T> clazz); @NonNull @CheckReturnValue static Single<T> dataOf(
            @NonNull Query query, @NonNull Class<T> clazz); @NonNull @CheckReturnValue static Single<T> dataOf(
            @NonNull DatabaseReference ref, @NonNull GenericTypeIndicator<T> typeIndicator); @NonNull @CheckReturnValue static Single<T> dataOf(
            @NonNull Query query, @NonNull GenericTypeIndicator<T> typeIndicator); @NonNull @CheckReturnValue static Completable removeValue(@NonNull final DatabaseReference ref); @NonNull @CheckReturnValue static Completable setPriority(
            @NonNull final DatabaseReference ref, @NonNull final Object priority); @NonNull @CheckReturnValue static Completable setValue(
            @NonNull final DatabaseReference ref,
            @NonNull final T value); @NonNull @CheckReturnValue static Completable setValue(
            @NonNull final DatabaseReference ref,
            @NonNull final T value,
            @NonNull final Object priority); @NonNull @CheckReturnValue static Single<DataSnapshot> runTransaction(
            @NonNull final DatabaseReference ref,
            @NonNull final Function<MutableData, Transaction.Result> function); @NonNull @CheckReturnValue static Single<DataSnapshot> runTransaction(
            @NonNull final DatabaseReference ref,
            @NonNull final Function<MutableData, Transaction.Result> function,
            final boolean fireLocalEvents); @NonNull @CheckReturnValue static Completable updateChildren(
            @NonNull final DatabaseReference ref, @NonNull final Map<String, Object> map); }
RxFirebaseDatabase { @NonNull @CheckReturnValue public static Observable<ChildEvent> childEvents(@NonNull final Query query) { return Observable.create(new QueryChildEventsOnSubscribe(query)); } private  RxFirebaseDatabase(); @NonNull @CheckReturnValue static Observable<ChildEvent> childEvents(@NonNull final Query query); @NonNull @CheckReturnValue static Single<DataSnapshot> data(@NonNull final Query query); @NonNull @CheckReturnValue static Observable<DataSnapshot> dataChanges(@NonNull final Query query); @NonNull @CheckReturnValue static Observable<DataValue<T>> dataChangesOf(
            @NonNull final DatabaseReference ref, @NonNull final Class<T> clazz); @NonNull @CheckReturnValue static Observable<DataValue<T>> dataChangesOf(
            @NonNull final Query query, @NonNull final Class<T> clazz); @NonNull @CheckReturnValue static Observable<DataValue<T>> dataChangesOf(
            @NonNull DatabaseReference ref, @NonNull GenericTypeIndicator<T> typeIndicator); @NonNull @CheckReturnValue static Observable<DataValue<T>> dataChangesOf(
            @NonNull Query query, @NonNull GenericTypeIndicator<T> typeIndicator); @NonNull @CheckReturnValue static Single<T> dataOf(
            @NonNull DatabaseReference ref, @NonNull Class<T> clazz); @NonNull @CheckReturnValue static Single<T> dataOf(
            @NonNull Query query, @NonNull Class<T> clazz); @NonNull @CheckReturnValue static Single<T> dataOf(
            @NonNull DatabaseReference ref, @NonNull GenericTypeIndicator<T> typeIndicator); @NonNull @CheckReturnValue static Single<T> dataOf(
            @NonNull Query query, @NonNull GenericTypeIndicator<T> typeIndicator); @NonNull @CheckReturnValue static Completable removeValue(@NonNull final DatabaseReference ref); @NonNull @CheckReturnValue static Completable setPriority(
            @NonNull final DatabaseReference ref, @NonNull final Object priority); @NonNull @CheckReturnValue static Completable setValue(
            @NonNull final DatabaseReference ref,
            @NonNull final T value); @NonNull @CheckReturnValue static Completable setValue(
            @NonNull final DatabaseReference ref,
            @NonNull final T value,
            @NonNull final Object priority); @NonNull @CheckReturnValue static Single<DataSnapshot> runTransaction(
            @NonNull final DatabaseReference ref,
            @NonNull final Function<MutableData, Transaction.Result> function); @NonNull @CheckReturnValue static Single<DataSnapshot> runTransaction(
            @NonNull final DatabaseReference ref,
            @NonNull final Function<MutableData, Transaction.Result> function,
            final boolean fireLocalEvents); @NonNull @CheckReturnValue static Completable updateChildren(
            @NonNull final DatabaseReference ref, @NonNull final Map<String, Object> map);  }