A callbag sink (listener) that connects an Observer a-la RxJS. 👜 - View it on GitHub