openedMessages

fun openedMessages(): Flux<E>

messages with processing opened on subscription: the stream a consumer that is ready at once reads, so a transport that gates consumption on openProcessing streams immediately. Like messages, it supports exactly one subscriber.