in tutorials/tutorial4/src/main/java/com/uber/rib/root/loggedin/offgame/OffGameInteractor.java [51:77]
protected void didBecomeActive(@Nullable Bundle savedInstanceState) {
super.didBecomeActive(savedInstanceState);
presenter.setPlayerNames(playerOne.getUserName(), playerTwo.getUserName());
presenter
.startGameRequest(gameNames)
.subscribe(
new Consumer<GameKey>() {
@Override
public void accept(GameKey gameKey) throws Exception {
listener.onStartGame(gameKey);
}
});
scoreStream
.scores()
.as(AutoDispose.<ImmutableMap<UserName, Integer>>autoDisposable(this))
.subscribe(
new Consumer<ImmutableMap<UserName, Integer>>() {
@Override
public void accept(ImmutableMap<UserName, Integer> scores) throws Exception {
Integer playerOneScore = scores.get(playerOne);
Integer playerTwoScore = scores.get(playerTwo);
presenter.setScores(playerOneScore, playerTwoScore);
}
});
}