Modifier and Type	Class and Description
pack-priv class	SingleDelay.Delay

Modifier and Type	Field and Description
pack-priv final boolean	delayError
pack-priv final Scheduler	scheduler
pack-priv final SingleSource<? extends T>	source
pack-priv final long	time
pack-priv final TimeUnit	unit

Access	Constructor and Description
public	SingleDelay(SingleSource<? extends T> source, long time, TimeUnit unit, Scheduler scheduler, boolean delayError)

Modifier and Type	Method and Description
protected void	subscribeActual(final SingleObserver<? super T> the SingleObserver to handle, not null observer) Implements abstract io.reactivex.Single.subscribeActual. Implement this method in subclasses to handle the incoming `SingleObserver`s.

delayError	back to summary
pack-priv final boolean delayError

scheduler	back to summary
pack-priv final Scheduler scheduler

source	back to summary
pack-priv final SingleSource<? extends T> source

time	back to summary
pack-priv final long time

unit	back to summary
pack-priv final TimeUnit unit

SingleDelay	back to summary
public SingleDelay(SingleSource<? extends T> source, long time, TimeUnit unit, Scheduler scheduler, boolean delayError)

subscribeActual	back to summary
protected void subscribeActual(final SingleObserver<? super T> observer) Implements abstract io.reactivex.Single.subscribeActual. Doc from io.reactivex.Single.subscribeActual. Implement this method in subclasses to handle the incoming `SingleObserver`s. There is no need to call any of the plugin hooks on the current `Single` instance or the `SingleObserver`; all hooks and basic safeguards have been applied by `subscribe(SingleObserver)` before this method gets called. Parameters observer:SingleObserver<? super T> the SingleObserver to handle, not null Annotations @Override

io.reactivex.internal.operators.single back to summary

pack-priv final Class SingleDelay.Delay

Class Inheritance

extends Object
implements SingleObserver<T>

java.lang.Object
io.reactivex.internal.operators.single.SingleDelay.Delay

All Implemented Interfaces

io.reactivex.SingleObserver

Nested and Inner Type Summary

Modifier and Type	Class and Description
pack-priv class	SingleDelay.Delay.OnError
pack-priv class	SingleDelay.Delay.OnSuccess

Field Summary

Modifier and Type	Field and Description
pack-priv final SingleObserver<? super T>	downstream
private final SequentialDisposable	sd

Constructor Summary

Access	Constructor and Description
pack-priv	Delay(SequentialDisposable sd, SingleObserver<? super T> observer)

Method Summary

Modifier and Type	Method and Description
public void	onError(final Throwable the exception encountered by the Single e) Implements io.reactivex.SingleObserver.onError. Notifies the SingleObserver that the `Single` has experienced an error condition.
public void	onSubscribe(Disposable the Disposable instance whose `Disposable#dispose()` can be called anytime to cancel the connection d) Implements io.reactivex.SingleObserver.onSubscribe. Provides the SingleObserver with the means of cancelling (disposing) the connection (channel) with the Single in both synchronous (from within `onSubscribe(Disposable)` itself) and asynchronous manner.
public void	onSuccess(final T the item emitted by the Single value) Implements io.reactivex.SingleObserver.onSuccess. Notifies the SingleObserver with a single item and that the `Single` has finished sending push-based notifications.

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

downstream	back to summary
pack-priv final SingleObserver<? super T> downstream

sd	back to summary
private final SequentialDisposable sd

Constructor Detail

Delay	back to summary
pack-priv Delay(SequentialDisposable sd, SingleObserver<? super T> observer)

Method Detail

onError back to summary

onError	back to summary
public void onError(final Throwable e) Implements io.reactivex.SingleObserver.onError. Doc from io.reactivex.SingleObserver.onError. Notifies the SingleObserver that the `Single` has experienced an error condition. If the `Single` calls this method, it will not thereafter call `onSuccess`. Parameters e:Throwable the exception encountered by the Single Annotations @Override

public void onError(final Throwable e)

Implements io.reactivex.SingleObserver.onError.

Doc from io.reactivex.SingleObserver.onError.

Notifies the SingleObserver that the Single has experienced an error condition.

If the Single calls this method, it will not thereafter call onSuccess.

Parameters

e:Throwable: the exception encountered by the Single

Annotations

@Override

onSubscribe back to summary

onSubscribe	back to summary
public void onSubscribe(Disposable d) Implements io.reactivex.SingleObserver.onSubscribe. Doc from io.reactivex.SingleObserver.onSubscribe. Provides the SingleObserver with the means of cancelling (disposing) the connection (channel) with the Single in both synchronous (from within `onSubscribe(Disposable)` itself) and asynchronous manner. Parameters d:Disposable the Disposable instance whose `Disposable#dispose()` can be called anytime to cancel the connection Annotations @Override

public void onSubscribe(Disposable d)

Implements io.reactivex.SingleObserver.onSubscribe.

Doc from io.reactivex.SingleObserver.onSubscribe.

Provides the SingleObserver with the means of cancelling (disposing) the connection (channel) with the Single in both synchronous (from within onSubscribe(Disposable) itself) and asynchronous manner.

Parameters

d:Disposable: the Disposable instance whose Disposable#dispose() can be called anytime to cancel the connection

Annotations

@Override

onSuccess back to summary

onSuccess	back to summary
public void onSuccess(final T value) Implements io.reactivex.SingleObserver.onSuccess. Doc from io.reactivex.SingleObserver.onSuccess. Notifies the SingleObserver with a single item and that the `Single` has finished sending push-based notifications. The `Single` will not call this method if it calls `onError`. Parameters value:T the item emitted by the Single Annotations @Override

public void onSuccess(final T value)

Implements io.reactivex.SingleObserver.onSuccess.

Doc from io.reactivex.SingleObserver.onSuccess.

Notifies the SingleObserver with a single item and that the Single has finished sending push-based notifications.

The Single will not call this method if it calls onError.

Parameters