``` init { disposables += onSe...

# rx

[ursus]

init {
            disposables += onSendMessageObservable(sendMessageObservable)
        }
            
       open fun onSendMessageObservable(sendObservable: Observable<Unit>): Disposable {
            return sendObservable
            .ofType(Enabled.Edit::class.java)
            .flatMap {
                messageManager.editMessage(channelId, it.message.id, it.text)
                    .asEvents2()
            }
            .observeOn(mainThreadScheduler)
            .subscribe {
                if (it is Event2.Success) {
                    bottomBarDelegate.process(MessageSent)
                }
                editEventsRelay.accept(it)
            }
        }