subscribe

fun <T> Observable<T>.subscribe(subscriber: Subscriber<in T>): Subscription

Subscribe to the Observable

Return

created Subscription

Parameters

subscriber

the Subscriber that will handle emissions and notifications from the Observable

See also


fun <T> Observable<T>.subscribe(onNext: T.() -> Unit): Subscription

Subscribe to the Observable. This is equivalent to subscribe(createActionSubscriber(onNext))

Return

created Subscription

Parameters

onNext

the callback that will be fired once the Observable emits onNext

See also