@Test public void canObserveUsers() { Observable<Users> usersObservable = firebaseUserDatabase.observeUsers(); assertValueReceivedOnNext(usersObservable, users); }
@Override public Observable<Users> observeUsers() { return firebaseObservableListeners.listenToValueEvents(usersDB, toUsers()); }
FirebaseUserDatabase implements UserDatabase { @Override public Observable<Users> observeUsers() { return firebaseObservableListeners.listenToValueEvents(usersDB, toUsers()); } }
FirebaseUserDatabase implements UserDatabase { @Override public Observable<Users> observeUsers() { return firebaseObservableListeners.listenToValueEvents(usersDB, toUsers()); } FirebaseUserDatabase(FirebaseDatabase firebaseDatabase, FirebaseObservableListeners firebaseObservableListeners); }
FirebaseUserDatabase implements UserDatabase { @Override public Observable<Users> observeUsers() { return firebaseObservableListeners.listenToValueEvents(usersDB, toUsers()); } FirebaseUserDatabase(FirebaseDatabase firebaseDatabase, FirebaseObservableListeners firebaseObservableListeners); @Override Observable<Users> observeUsers(); @Override Observable<User> readUserFrom(String userId); @Override Observable<User> observeUser(String userId); @Override void writeCurrentUser(User user); }
FirebaseUserDatabase implements UserDatabase { @Override public Observable<Users> observeUsers() { return firebaseObservableListeners.listenToValueEvents(usersDB, toUsers()); } FirebaseUserDatabase(FirebaseDatabase firebaseDatabase, FirebaseObservableListeners firebaseObservableListeners); @Override Observable<Users> observeUsers(); @Override Observable<User> readUserFrom(String userId); @Override Observable<User> observeUser(String userId); @Override void writeCurrentUser(User user);  }