hu.akarnokd.rxjava2.internal.subscribers.nbp

Class NbpDisposableSubscriber<T>

java.lang.Object

hu.akarnokd.rxjava2.internal.subscribers.nbp.NbpDisposableSubscriber<T>

Type Parameters:

T -

All Implemented Interfaces:

Disposable, NbpObservable.NbpSubscriber<T>

public abstract class NbpDisposableSubscriber<T>
extends java.lang.Object
implements NbpObservable.NbpSubscriber<T>, Disposable

An abstract subscription that allows asynchronous cancellation.

Constructor Summary

Constructors

Constructor and Description
NbpDisposableSubscriber()

Method Summary

Modifier and Type	Method and Description
void	dispose() Dispose the resource, the operation should be idempotent.
boolean	isDisposed()
protected void	onStart()
void	onSubscribe(Disposable s)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface hu.akarnokd.rxjava2.NbpObservable.NbpSubscriber

onComplete, onError, onNext

Constructor Detail

NbpDisposableSubscriber

public NbpDisposableSubscriber()

Method Detail

onSubscribe

public final void onSubscribe(Disposable s)

Specified by:

onSubscribe in interface NbpObservable.NbpSubscriber<T>

onStart

protected void onStart()

isDisposed

public final boolean isDisposed()

dispose

public final void dispose()

Description copied from interface: Disposable

Dispose the resource, the operation should be idempotent.

Specified by:

dispose in interface Disposable