Callbag operator that rescues a failed source - View it on GitHub