hu.akarnokd.rxjava2.internal.subscribers

Class DisposableSubscriber<T>

java.lang.Object

hu.akarnokd.rxjava2.internal.subscribers.DisposableSubscriber<T>

Type Parameters:

T -

All Implemented Interfaces:

Disposable, org.reactivestreams.Subscriber<T>

public abstract class DisposableSubscriber<T>
extends java.lang.Object
implements org.reactivestreams.Subscriber<T>, Disposable

An abstract subscription that allows asynchronous cancellation.

Constructor Summary

Constructors

Constructor and Description
DisposableSubscriber()

Method Summary

Modifier and Type	Method and Description
protected void	cancel()
void	dispose() Dispose the resource, the operation should be idempotent.
boolean	isDisposed()
protected void	onStart()
void	onSubscribe(org.reactivestreams.Subscription s)
protected void	request(long n)
protected org.reactivestreams.Subscription	subscription()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.reactivestreams.Subscriber

onComplete, onError, onNext

Constructor Detail

DisposableSubscriber

public DisposableSubscriber()

Method Detail

onSubscribe

public final void onSubscribe(org.reactivestreams.Subscription s)

Specified by:

onSubscribe in interface org.reactivestreams.Subscriber<T>

subscription

protected final org.reactivestreams.Subscription subscription()

onStart

protected void onStart()

request

protected final void request(long n)

cancel

protected final void cancel()

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