mapMessages

fun <R : Any> mapMessages(transform: (Flux<E>) -> Flux<R>): MessageReceiver<R>