Top Inners Fields Constructors Methods
rx.internal.operators

public final Class OnSubscribeTakeLastOne<T>

extends Object
implements Observable.OnSubscribe<T>
Class Inheritance
All Implemented Interfaces
rx.Observable.OnSubscribe, rx.functions.Action1, rx.functions.Action, rx.functions.Function
Imports
rx.*, .Observable.OnSubscribe

Nested and Inner Type Summary

Modifier and TypeClass and Description
pack-priv static class
OnSubscribeTakeLastOne.TakeLastOneSubscriber<T>

Field Summary

Modifier and TypeField and Description
pack-priv final Observable<T>
source

Constructor Summary

AccessConstructor and Description
public
OnSubscribeTakeLastOne(Observable<T> source)

Method Summary

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

Implements rx.functions.Action1.call.

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

sourceback to summary
pack-priv final Observable<T> source

Constructor Detail

OnSubscribeTakeLastOneback to summary
public OnSubscribeTakeLastOne(Observable<T> source)

Method Detail

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

Implements rx.functions.Action1.call.

Annotations
@Override
rx.internal.operators back to summary

pack-priv final Class OnSubscribeTakeLastOne.TakeLastOneSubscriber<T>

extends DeferredScalarSubscriber<T, T>
Class Inheritance

Field Summary

Modifier and TypeField and Description
pack-priv static final Object
EMPTY

Inherited from rx.internal.operators.DeferredScalarSubscriber:
actualHAS_REQUEST_HAS_VALUEHAS_REQUEST_NO_VALUEhasValueNO_REQUEST_HAS_VALUENO_REQUEST_NO_VALUEstatevalue

Constructor Summary

AccessConstructor and Description
public
TakeLastOneSubscriber(Subscriber<? super T> actual)

Method Summary

Modifier and TypeMethod and Description
public void
onCompleted()

Overrides rx.internal.operators.DeferredScalarSubscriber.onCompleted.

Implements rx.Observer.onCompleted.

Notifies the Observer that the Observable has finished sending push-based notifications.
public void
onNext(T
the item emitted by the Observable
t)

Implements rx.Observer.onNext.

Provides the Observer with a new item to observe.
Inherited from rx.internal.operators.DeferredScalarSubscriber:
completecompletedownstreamRequestonErrorsetProducersetupDownstreamsubscribeTo

Field Detail

EMPTYback to summary
pack-priv static final Object EMPTY

Constructor Detail

TakeLastOneSubscriberback to summary
public TakeLastOneSubscriber(Subscriber<? super T> actual)
Annotations
@SuppressWarnings:unchecked

Method Detail

onCompletedback to summary
public void onCompleted()

Overrides rx.internal.operators.DeferredScalarSubscriber.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
@SuppressWarnings:unchecked
@Override
onNextback to summary
public void onNext(T t)

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
t:T

the item emitted by the Observable

Annotations
@Override