com.github.kongpf8848.rx.math.operators

类 ScalarDeferredSubscriber<T,R>

java.lang.Object

com.github.kongpf8848.rx.math.operators.ScalarDeferredSubscriber<T,R>

所有已实现的接口:

io.reactivex.Observer<T>

public abstract class ScalarDeferredSubscriber<T,R>
extends java.lang.Object
implements io.reactivex.Observer<T>

字段概要

字段

限定符和类型	字段和说明
protected io.reactivex.disposables.Disposable	disposable
protected boolean	hasValue
protected R	value

构造器概要

构造器

构造器和说明
ScalarDeferredSubscriber(io.reactivex.ObservableEmitter<? super R> actual)

方法概要

限定符和类型	方法和说明
protected void	complete(R v)
void	onComplete()
void	onError(java.lang.Throwable e)
void	onSubscribe(io.reactivex.disposables.Disposable d)
void	subscribeTo(io.reactivex.Observable<T> source)

从类继承的方法 java.lang.Object

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

从接口继承的方法 io.reactivex.Observer

onNext

字段详细资料

hasValue

protected boolean hasValue

value

protected R value

disposable

protected io.reactivex.disposables.Disposable disposable

构造器详细资料

ScalarDeferredSubscriber

public ScalarDeferredSubscriber(io.reactivex.ObservableEmitter<? super R> actual)

方法详细资料

onError

public final void onError(java.lang.Throwable e)

指定者:

onError 在接口中 io.reactivex.Observer<T>

onComplete

public void onComplete()

指定者:

onComplete 在接口中 io.reactivex.Observer<T>

complete

protected final void complete(R v)

onSubscribe

public void onSubscribe(io.reactivex.disposables.Disposable d)

指定者:

onSubscribe 在接口中 io.reactivex.Observer<T>

subscribeTo

public final void subscribeTo(io.reactivex.Observable<T> source)