in tutorials/tutorial3-completed/src/main/java/com/uber/rib/root/loggedin/offgame/OffGameInteractor.java [48:74]
protected void didBecomeActive(@Nullable Bundle savedInstanceState) {
super.didBecomeActive(savedInstanceState);
presenter.setPlayerNames(playerOne, playerTwo);
presenter
.startGameRequest()
.subscribe(
new Consumer<Object>() {
@Override
public void accept(Object object) throws Exception {
listener.onStartGame();
}
});
scoreStream
.scores()
.as(AutoDispose.<ImmutableMap<String, Integer>>autoDisposable(this))
.subscribe(
new Consumer<ImmutableMap<String, Integer>>() {
@Override
public void accept(ImmutableMap<String, Integer> scores) throws Exception {
Integer playerOneScore = scores.get(playerOne);
Integer playerTwoScore = scores.get(playerTwo);
presenter.setScores(playerOneScore, playerTwoScore);
}
});
}