streamMessages

fun streamMessages(): Flow<Message>