rx: Provide a way to safely cancel subscription inside the Rx operators #3689
Description
var c = Cancelable.empty
c = rx.map(x => if cond then c.cancel) // This throws concurrent modification exception
c.run()We need a way to send Completion event