Bridging Reactive streams to Native Callbacks

Convert asynchronous shared flows into native-friendly delegates or observers.