@Test public void testRunTransaction_onError() { TestObserver sub = TestObserver.create(); RxFirebaseDatabase .runTransaction(mockDatabaseReference, mockTransactionTask) .subscribe(sub); verifyRunTransaction(); callTransactionOnCompleteWithError(new DatabaseException("Foo")); sub.assertNotComplete(); sub.assertError(DatabaseException.class); sub.dispose(); }
@NonNull @CheckReturnValue public static Single<DataSnapshot> runTransaction( @NonNull final DatabaseReference ref, @NonNull final Function<MutableData, Transaction.Result> function) { return RxValue.transaction(ref, function); }
RxFirebaseDatabase { @NonNull @CheckReturnValue public static Single<DataSnapshot> runTransaction( @NonNull final DatabaseReference ref, @NonNull final Function<MutableData, Transaction.Result> function) { return RxValue.transaction(ref, function); } }
RxFirebaseDatabase { @NonNull @CheckReturnValue public static Single<DataSnapshot> runTransaction( @NonNull final DatabaseReference ref, @NonNull final Function<MutableData, Transaction.Result> function) { return RxValue.transaction(ref, function); } private  RxFirebaseDatabase(); }
RxFirebaseDatabase { @NonNull @CheckReturnValue public static Single<DataSnapshot> runTransaction( @NonNull final DatabaseReference ref, @NonNull final Function<MutableData, Transaction.Result> function) { return RxValue.transaction(ref, function); } 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 Single<DataSnapshot> runTransaction( @NonNull final DatabaseReference ref, @NonNull final Function<MutableData, Transaction.Result> function) { return RxValue.transaction(ref, function); } 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);  }