Andre Staltz explains a unification of asynchronous functional handlers called callbags.
With this model you can make simple composable streaming functions (like callbacks, promises and observables) which allow for two way conversations.
In other words sinks that can also be sources and vica versa, emitters that can also be listeners and vica versa.



