ConcurrentManySink
class ConcurrentManySink<T : Any>(val delegate: Sinks.Many<T>) : Sinks.Many<T> , Decorator<Sinks.Many<T>>
Concurrent-emission Sinks.Many decorator.
Reactor sinks reject concurrent emissions with Sinks.EmitResult.FAIL_NON_SERIALIZED. A ReentrantLock serializes every emission call on its originating thread, preserving synchronous results, exception identity, thread-local context and downstream reentrancy. Subscription, scan and subscriber-count operations are delegated without acquiring this lock.
Parameters
delegate
sink whose emissions are serialized
Type Parameters
T
non-null element type