Top Description Inners Fields Constructors Methods
rx.internal.operators

public final Class SingleDelay<T>

extends Object
implements Single.OnSubscribe<T>
Class Inheritance
All Implemented Interfaces
rx.Single.OnSubscribe, rx.functions.Action1, rx.functions.Action, rx.functions.Function
Type Parameters
<T>
the value type
Imports
java.util.concurrent.TimeUnit, rx.*, .Scheduler.Worker, .Single.OnSubscribe, rx.functions.Action0
Signal the success or error value on the Scheduler's thread.

Nested and Inner Type Summary

Modifier and TypeClass and Description
pack-priv static class
SingleDelay.ObserveOnSingleSubscriber<T>

Field Summary

Modifier and TypeField and Description
pack-priv final long
delay

pack-priv final Scheduler
scheduler

pack-priv final Single.OnSubscribe<T>
source

pack-priv final TimeUnit
unit

Constructor Summary

AccessConstructor and Description
public
SingleDelay(Single.OnSubscribe<T> source, long delay, TimeUnit unit, Scheduler scheduler)

Method Summary

Modifier and TypeMethod and Description
public void
call(SingleSubscriber<? super T> t)

Implements rx.functions.Action1.call.

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

delayback to summary
pack-priv final long delay
schedulerback to summary
pack-priv final Scheduler scheduler
sourceback to summary
pack-priv final Single.OnSubscribe<T> source
unitback to summary
pack-priv final TimeUnit unit

Constructor Detail

SingleDelayback to summary
public SingleDelay(Single.OnSubscribe<T> source, long delay, TimeUnit unit, Scheduler scheduler)

Method Detail

callback to summary
public void call(SingleSubscriber<? super T> t)

Implements rx.functions.Action1.call.

Annotations
@Override
rx.internal.operators back to summary

pack-priv final Class SingleDelay.ObserveOnSingleSubscriber<T>

extends SingleSubscriber<T>
implements Action0
Class Inheritance
All Implemented Interfaces
rx.functions.Action0, rx.functions.Action, rx.functions.Function

Field Summary

Modifier and TypeField and Description
pack-priv final SingleSubscriber<? super T>
actual

pack-priv final long
delay

pack-priv Throwable
error

pack-priv final TimeUnit
unit

pack-priv T
value

pack-priv final Scheduler.Worker
w

Constructor Summary

AccessConstructor and Description
public
ObserveOnSingleSubscriber(SingleSubscriber<? super T> actual, Scheduler.Worker w, long delay, TimeUnit unit)

Method Summary

Modifier and TypeMethod and Description
public void
call()

Implements rx.functions.Action0.call.

public void
onError(Throwable
the exception encountered by the Single
error)

Implements abstract rx.SingleSubscriber.onError.

Notifies the SingleSubscriber that the Single has experienced an error condition.
public void
onSuccess(T
the item emitted by the Single
value)

Implements abstract rx.SingleSubscriber.onSuccess.

Notifies the SingleSubscriber with a single item and that the Single has finished sending push-based notifications.
Inherited from rx.SingleSubscriber:
addisUnsubscribedunsubscribe

Field Detail

actualback to summary
pack-priv final SingleSubscriber<? super T> actual
delayback to summary
pack-priv final long delay
errorback to summary
pack-priv Throwable error
unitback to summary
pack-priv final TimeUnit unit
valueback to summary
pack-priv T value
wback to summary
pack-priv final Scheduler.Worker w

Constructor Detail

ObserveOnSingleSubscriberback to summary
public ObserveOnSingleSubscriber(SingleSubscriber<? super T> actual, Scheduler.Worker w, long delay, TimeUnit unit)

Method Detail

callback to summary
public void call()

Implements rx.functions.Action0.call.

Annotations
@Override
onErrorback to summary
public void onError(Throwable error)

Implements abstract rx.SingleSubscriber.onError.

Doc from rx.SingleSubscriber.onError.

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

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

Parameters
error:Throwable

the exception encountered by the Single

Annotations
@Override
onSuccessback to summary
public void onSuccess(T value)

Implements abstract rx.SingleSubscriber.onSuccess.

Doc from rx.SingleSubscriber.onSuccess.

Notifies the SingleSubscriber 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