Top Description Inners Fields Constructors Methods
rx.internal.operators

public final Class SingleTakeUntilObservable<T, U>

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
<U>
the other's value type (not relevant)
Imports
java.util.concurrent.CancellationException, java.util.concurrent.atomic.AtomicBoolean, rx.*, .Single.OnSubscribe, rx.plugins.RxJavaHooks
Relay the source signals if the other doesn't terminate before.

Nested and Inner Type Summary

Modifier and TypeClass and Description
pack-priv static class
SingleTakeUntilObservable.TakeUntilSourceSubscriber<T, U>

Field Summary

Modifier and TypeField and Description
pack-priv final Observable<? extends U>
other

pack-priv final Single.OnSubscribe<T>
source

Constructor Summary

AccessConstructor and Description
public
SingleTakeUntilObservable(Single.OnSubscribe<T> source, Observable<? extends U> other)

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

otherback to summary
pack-priv final Observable<? extends U> other
sourceback to summary
pack-priv final Single.OnSubscribe<T> source

Constructor Detail

SingleTakeUntilObservableback to summary
public SingleTakeUntilObservable(Single.OnSubscribe<T> source, Observable<? extends U> other)

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 SingleTakeUntilObservable.TakeUntilSourceSubscriber<T, U>

extends SingleSubscriber<T>
Class Inheritance

Nested and Inner Type Summary

Modifier and TypeClass and Description
pack-priv class
SingleTakeUntilObservable.TakeUntilSourceSubscriber.OtherSubscriber

Field Summary

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

pack-priv final AtomicBoolean
once

pack-priv final Subscriber<U>
other

Constructor Summary

AccessConstructor and Description
pack-priv
TakeUntilSourceSubscriber(SingleSubscriber<? super T> actual)

Method Summary

Modifier and TypeMethod and Description
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
onceback to summary
pack-priv final AtomicBoolean once
otherback to summary
pack-priv final Subscriber<U> other

Constructor Detail

TakeUntilSourceSubscriberback to summary
pack-priv TakeUntilSourceSubscriber(SingleSubscriber<? super T> actual)

Method Detail

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
rx.internal.operators back to summary

pack-priv final Class SingleTakeUntilObservable.TakeUntilSourceSubscriber.OtherSubscriber

extends Subscriber<U>
Class Inheritance

Constructor Summary

AccessConstructor and Description
pack-priv
OtherSubscriber()

Method Summary

Modifier and TypeMethod and Description
public void
onCompleted()

Implements rx.Observer.onCompleted.

Notifies the Observer that the Observable has finished sending push-based notifications.
public void
onError(Throwable
the exception encountered by the Observable
error)

Implements rx.Observer.onError.

Notifies the Observer that the Observable has experienced an error condition.
public void
onNext(U
the item emitted by the Observable
value)

Implements rx.Observer.onNext.

Provides the Observer with a new item to observe.
Inherited from rx.Subscriber:
addisUnsubscribedonStartrequestsetProducerunsubscribe

Constructor Detail

OtherSubscriberback to summary
pack-priv OtherSubscriber()

Method Detail

onCompletedback to summary
public void onCompleted()

Implements rx.Observer.onCompleted.

Doc from rx.Observer.onCompleted.

Notifies the Observer that the Observable has finished sending push-based notifications.

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

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

Implements rx.Observer.onError.

Doc from rx.Observer.onError.

Notifies the Observer that the Observable has experienced an error condition.

If the Observable calls this method, it will not thereafter call onNext or onCompleted.

Parameters
error:Throwable

the exception encountered by the Observable

Annotations
@Override
onNextback to summary
public void onNext(U value)

Implements rx.Observer.onNext.

Doc from rx.Observer.onNext.

Provides the Observer with a new item to observe.

The Observable may call this method 0 or more times.

The Observable will not call this method again after it calls either onCompleted or onError.

Parameters
value:U

the item emitted by the Observable

Annotations
@Override