Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- Single<DialogsTable> managerDialogSingle = Single.fromCallable(() ->
- DialogsTable.getDialogByOpponentId(App.newInstance().getManagers().get(0).getManagerId()));
- Single<VehiclesTable> vehicleSingle = Single.fromCallable(() -> {
- DialogsTable dialogsTable = DialogsTable.getDialogById(getDialogId());
- return VehiclesTable.getCarById(dialogsTable.getCarId());
- });
- Single<String> userSingle = Single.fromCallable(() -> {
- DialogsTable dialog = DialogsTable.getDialogById(getDialogId());
- UsersTable user = UsersTable.getUserWithID(dialog.getOpponentId());
- String userName = user.getUserName();
- if (!user.getUserSureName().isEmpty()) {
- userName += " " + user.getUserSureName();
- }
- return userName;
- });
- Single.zip(managerDialogSingle, vehicleSingle, userSingle, Tripple::new)
- .subscribeOn(Schedulers.io())
- .observeOn(Schedulers.io())
- .subscribe((pair, throwable) -> {
- MessagesTable.createManagerChangeStatusMessage(pair.first.getDialogId(), statusName, endDate, pair.third, pair.second.getCarName(), statusChangeType);
- });
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement