ursus
07/15/2019, 12:29 AMdisposables += sendMessageObservable
.ofType(Enabled.Edit::class.java)
.flatMap {
messageManager.editMessage(it.text).asEvents()
}
.observeOn(mainThreadScheduler)
.throwingSubscribe {
if (it is Event2.Success) {
bottomBarDelegate.process(MessageSent)
}
editEventsRelay.accept(it)
}