hu.akarnokd.rxjava2

Class Observer<T>

java.lang.Object

hu.akarnokd.rxjava2.Observer<T>

All Implemented Interfaces:

org.reactivestreams.Subscriber<T>

public abstract class Observer<T>
extends java.lang.Object
implements org.reactivestreams.Subscriber<T>

Constructor Summary

Constructors

Constructor and Description
Observer()

Method Summary

Modifier and Type	Method and Description
protected void	cancel()
protected void	onStart() Called once the subscription has been set on this observer; override this to perform initialization or issue an initial request.
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

Observer

public Observer()

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()

request

protected final void request(long n)

cancel

protected final void cancel()

onStart

protected void onStart()

Called once the subscription has been set on this observer; override this to perform initialization or issue an initial request.

The default implementation requests Long.MAX_VALUE.