In this model, Cancellation tokens replace Subscriptions. Instead of an Observable creating a Subscription object when subscribe is called, the consumer creates a CT and passes it to the subscribe method alongside an Observer. Internally each Observable creates its own CT, registers all of its cleanup behavior to run on its CT’s cancellation, then links the internal CT with the one passed to the s