Callbag operator that combines consecutive values from the same source - View it on GitHub