Reactive Programming with Multiprocessing

Greeting, I am trying to combine coding in a reactive framework like Rocket.jl with multiprocessing. The idea is to have different actors working in different cores. It’s natural to write in a reactive framework to leverage multiple CPU cores. But the question is how to enable messages to flow into different cores? For example, as an observable lives on core 1, how would an actor living on core 2 subscribe to this observable? Thank you.