subscribe

abstract fun subscribe(priority: Int = Priority.DEFAULT, subscriber: Subscriber<T>): Unsubscriber

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

Return

A function to unsubscribe.