diff --git a/app/src/main/java/com/example/sprout/refactor/model/RoomModel.java b/app/src/main/java/com/example/sprout/refactor/model/RoomModel.java index 468313a..f0cc750 100644 --- a/app/src/main/java/com/example/sprout/refactor/model/RoomModel.java +++ b/app/src/main/java/com/example/sprout/refactor/model/RoomModel.java @@ -26,12 +26,8 @@ roomRepository.getRoom(roomId) .subscribeOn(Schedulers.computation()) .subscribe( - room -> { - roomSubject.onNext(room); - }, - error -> { - errorSubject.onNext(new Error(error)); - }); + room -> roomSubject.onNext(room), + error -> errorSubject.onNext(new Error(error))); } public void clearStream() {