observe

abstract fun observe(onMessage: suspend (String) -> Unit)