writeReceiverGroup

fun <T> Flux<T>.writeReceiverGroup(receiverGroup: String): Flux<T>

Writes the receiver group to the Reactor context for this Flux.

This allows downstream operators to access the receiver group via the context.

Return

A new Flux with the receiver group in its context

Parameters

receiverGroup

The receiver group to write to the context