subscribe

open override fun subscribe(priority: Int, subscriber: Subscriber<T>): Unsubscriber

Subscribers have to be aware to unsubscribe when the scope of the subscriber is destroyed.

A function to unsubscribe.