`unsubscriptionCallback` is not a good name in Rx. `s` should be enough. And why not use `add(Subscription(s))`? The codes here are almost same as `Subscription.apply(u: => Unit)`.