rx: Provide a way to safely cancel subscription inside the Rx operators

[xerial]

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