streamMessages

fun streamMessages(onClose: () -> Unit? = null): Flow<DecodedMessage>