streamMessages

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

Acknowledges after the direct Flow collector returns. App-added buffering changes this boundary.