observeChat

open override fun observeChat(id: String, event: ReactiveEvent.TYPE): Flowable<ChatModel>