Callbag operator that applies a transformation on data passing through it - View it on GitHub