Best practice to integrate external push-based callbacks?

[space88man]

Problem:

I am looking to integrate 3rd party push-based callbacks - there may be several methods that need to imperatively push data - into a hot producer

Research:

Possibilities I've searched for:

• createFrom().emitter().broadcast().toAllSubscribers() - use the Consumer to store the MultiEmitter into the scope for the callbacks
• BroadcastProcessor, UnicastProcessor (from Mutiny docs)

Background:

• coming from a Reactor background I'm actually looking for the equivalent of Sinks.Many
• in the Reactor world the Processor abstraction has been removed, so does this (Broadcast|Unicast)Processor have the same issues?

Question:

Which is the best analog of Sinks.Many in Mutiny?

[jponge]

createFrom().emitter().broadcast().toAllSubscribers() is indeed a fine option.

• An emitter allows you to push events (just beware the backpressure, still)
• Broadcasting is interesting if you have multiple, fluctuating subscribers.