@Test public void canRetrieveUserObjectFromId() { Observable<User> userObservable = firebaseUserDatabase.readUserFrom(USER_ID); assertValueReceivedOnNext(userObservable, user); }
@Override public Observable<User> readUserFrom(String userId) { return firebaseObservableListeners.listenToSingleValueEvents(usersDB.child(userId), as(User.class)); }
FirebaseUserDatabase implements UserDatabase { @Override public Observable<User> readUserFrom(String userId) { return firebaseObservableListeners.listenToSingleValueEvents(usersDB.child(userId), as(User.class)); } }
FirebaseUserDatabase implements UserDatabase { @Override public Observable<User> readUserFrom(String userId) { return firebaseObservableListeners.listenToSingleValueEvents(usersDB.child(userId), as(User.class)); } FirebaseUserDatabase(FirebaseDatabase firebaseDatabase, FirebaseObservableListeners firebaseObservableListeners); }
FirebaseUserDatabase implements UserDatabase { @Override public Observable<User> readUserFrom(String userId) { return firebaseObservableListeners.listenToSingleValueEvents(usersDB.child(userId), as(User.class)); } 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<User> readUserFrom(String userId) { return firebaseObservableListeners.listenToSingleValueEvents(usersDB.child(userId), as(User.class)); } 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);  }