concurrent

Makes every emission method of this sink safe for concurrent producers.

Existing ConcurrentManySink instances are returned unchanged. Other sinks retain their original subscription, backpressure, terminal and scan-attribute behavior while emission calls are serialized on their caller threads.