    @Test
    public void fetchRemoteFailure() {

        TestObserver fetchTestObserver = RxFirebaseRemote
            .fetch(firebaseConfig, ANY_TIME)
            .test();

        testOnFailureListener.getValue().onFailure(EXCEPTION);

        verify(firebaseConfig).fetch(eq(ANY_TIME));

        fetchTestObserver.assertError(EXCEPTION)
            .assertNotComplete()
            .dispose();
    }