Modifier and Type	Class and Description
pack-priv static class	OperatorOnBackpressureLatest.Holder Holds a singleton instance initialized on class-loading.
pack-priv static class	OperatorOnBackpressureLatest.LatestEmitter<T> A terminable producer which emits the latest items on request.
pack-priv static class	OperatorOnBackpressureLatest.LatestSubscriber<T>

Access	Constructor and Description
public	OperatorOnBackpressureLatest()

Modifier and Type	Method and Description
public Subscriber<? super T>	call(Subscriber<? super T> child) Implements rx.functions.Func1.call.
public static < the value type T> OperatorOnBackpressureLatest<T>	Returns: the single instanceof OperatorOnBackpressureLatest instance() Returns a singleton instance of the OnBackpressureLatest operator since it is stateless.

OperatorOnBackpressureLatest	back to summary
public OperatorOnBackpressureLatest()

call	back to summary
public Subscriber<? super T> call(Subscriber<? super T> child) Implements rx.functions.Func1.call. Annotations @Override

instance	back to summary
public static <T> OperatorOnBackpressureLatest<T> instance() Returns a singleton instance of the OnBackpressureLatest operator since it is stateless. Parameters <T> the value type Returns:OperatorOnBackpressureLatest<T> the single instanceof OperatorOnBackpressureLatest Annotations @SuppressWarnings:unchecked

pack-priv final Class OperatorOnBackpressureLatest.Holder

Class Inheritance

extends Object

java.lang.Object
rx.internal.operators.OperatorOnBackpressureLatest.Holder

Holds a singleton instance initialized on class-loading.

Field Summary

Modifier and Type	Field and Description
pack-priv static final OperatorOnBackpressureLatest<Object>	INSTANCE

Constructor Summary

Access	Constructor and Description
pack-priv	Holder()

Method Summary

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

Field Detail

INSTANCE	back to summary
pack-priv static final OperatorOnBackpressureLatest<Object> INSTANCE

Constructor Detail

Holder	back to summary
pack-priv Holder()

rx.internal.operators back to summary

pack-priv final Class OperatorOnBackpressureLatest.LatestEmitter<T>

Class Inheritance

extends AtomicLong
implements Producer, Subscription, Observer<T>

java.lang.Object
java.lang.Number
java.util.concurrent.atomic.AtomicLong
rx.internal.operators.OperatorOnBackpressureLatest.LatestEmitter

All Implemented Interfaces

rx.Observer, rx.Subscription, rx.Producer

A terminable producer which emits the latest items on request.

Field Summary

Modifier and Type	Field and Description
pack-priv final Subscriber<? super T>	child
pack-priv volatile boolean	done
pack-priv boolean	emitting Guarded by this.
pack-priv static final Object	EMPTY
pack-priv boolean	missed Guarded by this.
pack-priv static final long	NOT_REQUESTED
pack-priv OperatorOnBackpressureLatest.LatestSubscriber<? super T>	parent
private static final long	serialVersionUID Hides java.util.concurrent.atomic.AtomicLong.serialVersionUID.
pack-priv Throwable	terminal Written before done, read after done.
pack-priv final AtomicReference<Object>	value Hides java.util.concurrent.atomic.AtomicLong.value.

Constructor Summary

Access	Constructor and Description
public	LatestEmitter(Subscriber<? super T> child)

Method Summary

Modifier and Type	Method and Description
pack-priv void	emit()
public boolean	isUnsubscribed() Implements rx.Subscription.isUnsubscribed. Indicates whether this `Subscription` is currently unsubscribed.
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 e) Implements rx.Observer.onError. Notifies the Observer that the `Observable` has experienced an error condition.
public void	onNext(T the item emitted by the Observable t) Implements rx.Observer.onNext. Provides the Observer with a new item to observe.
pack-priv long	produced(long n)
public void	request(long the maximum number of items you want this Producer to produce, or `Long.MAX_VALUE` if you want the Producer to produce items at its own pace n) Implements rx.Producer.request. Request a certain maximum number of items from this Producer.
public void	unsubscribe() Implements rx.Subscription.unsubscribe. Stops the receipt of notifications on the `Subscriber` that was registered when this Subscription was received.

Field Detail

child	back to summary
pack-priv final Subscriber<? super T> child

done	back to summary
pack-priv volatile boolean done

emitting	back to summary
pack-priv boolean emitting Guarded by this.

EMPTY	back to summary
pack-priv static final Object EMPTY

missed	back to summary
pack-priv boolean missed Guarded by this.

NOT_REQUESTED	back to summary
pack-priv static final long NOT_REQUESTED

parent	back to summary
pack-priv OperatorOnBackpressureLatest.LatestSubscriber<? super T> parent

serialVersionUID	back to summary
private static final long serialVersionUID Hides java.util.concurrent.atomic.AtomicLong.serialVersionUID.

terminal	back to summary
pack-priv Throwable terminal Written before done, read after done.

value	back to summary
pack-priv final AtomicReference<Object> value Hides java.util.concurrent.atomic.AtomicLong.value.

Constructor Detail

LatestEmitter	back to summary
public LatestEmitter(Subscriber<? super T> child)

Method Detail

emit	back to summary
pack-priv void emit()

isUnsubscribed back to summary

isUnsubscribed	back to summary
public boolean isUnsubscribed() Implements rx.Subscription.isUnsubscribed. Doc from rx.Subscription.isUnsubscribed. Indicates whether this `Subscription` is currently unsubscribed. Returns:boolean `true` if this `Subscription` is currently unsubscribed, `false` otherwise Annotations @Override

public boolean isUnsubscribed()

Implements rx.Subscription.isUnsubscribed.

Doc from rx.Subscription.isUnsubscribed.

Indicates whether this Subscription is currently unsubscribed.

Returns:boolean

true if this Subscription is currently unsubscribed, false otherwise

Annotations

@Override

onCompleted back to summary

onCompleted	back 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

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

onError back to summary

onError	back to summary
public void onError(Throwable e) 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 e:Throwable the exception encountered by the Observable Annotations @Override

public void onError(Throwable e)

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

e:Throwable: the exception encountered by the Observable

Annotations

@Override

onNext back to summary

onNext	back 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

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

produced	back to summary
pack-priv long produced(long n)

request back to summary

request	back to summary
public void request(long n) Implements rx.Producer.request. Doc from rx.Producer.request. Request a certain maximum number of items from this Producer. This is a way of requesting backpressure. To disable backpressure, pass `Long.MAX_VALUE` to this method. Requests are additive but if a sequence of requests totals more than `Long.MAX_VALUE` then `Long.MAX_VALUE` requests will be actioned and the extras may be ignored. Arriving at `Long.MAX_VALUE` by addition of requests cannot be assumed to disable backpressure. For example, the code below may result in `Long.MAX_VALUE` requests being actioned only. request(100); request(Long.MAX_VALUE-1); Parameters n:long the maximum number of items you want this Producer to produce, or `Long.MAX_VALUE` if you want the Producer to produce items at its own pace Annotations @Override

public void request(long n)

Implements rx.Producer.request.

Doc from rx.Producer.request.

Request a certain maximum number of items from this Producer. This is a way of requesting backpressure. To disable backpressure, pass Long.MAX_VALUE to this method.

Requests are additive but if a sequence of requests totals more than Long.MAX_VALUE then Long.MAX_VALUE requests will be actioned and the extras may be ignored. Arriving at Long.MAX_VALUE by addition of requests cannot be assumed to disable backpressure. For example, the code below may result in Long.MAX_VALUE requests being actioned only.

request(100);
request(Long.MAX_VALUE-1);

Parameters

n:long: the maximum number of items you want this Producer to produce, or Long.MAX_VALUE if you want the Producer to produce items at its own pace

Annotations

@Override

unsubscribe back to summary

unsubscribe	back to summary
public void unsubscribe() Implements rx.Subscription.unsubscribe. Doc from rx.Subscription.unsubscribe. Stops the receipt of notifications on the `Subscriber` that was registered when this Subscription was received. This allows deregistering an `Subscriber` before it has finished receiving all events (i.e. before onCompleted is called). Annotations @Override

public void unsubscribe()

Implements rx.Subscription.unsubscribe.

Doc from rx.Subscription.unsubscribe.

Stops the receipt of notifications on the Subscriber that was registered when this Subscription was received.

This allows deregistering an Subscriber before it has finished receiving all events (i.e. before onCompleted is called).

Annotations

@Override

rx.internal.operators back to summary

pack-priv final Class OperatorOnBackpressureLatest.LatestSubscriber<T>

Class Inheritance

extends Subscriber<T>

java.lang.Object
rx.Subscriber
rx.internal.operators.OperatorOnBackpressureLatest.LatestSubscriber

Field Summary

Modifier and Type	Field and Description
private final OperatorOnBackpressureLatest.LatestEmitter<T>	producer Hides rx.Subscriber.producer.

Constructor Summary

Access	Constructor and Description
pack-priv	LatestSubscriber(OperatorOnBackpressureLatest.LatestEmitter<T> producer)

Method Summary

Modifier and Type	Method 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 e) Implements rx.Observer.onError. Notifies the Observer that the `Observable` has experienced an error condition.
public void	onNext(T the item emitted by the Observable t) Implements rx.Observer.onNext. Provides the Observer with a new item to observe.
public void	onStart() Overrides rx.Subscriber.onStart. This method is invoked when the Subscriber and Observable have been connected but the Observable has not yet begun to emit items or send notifications to the Subscriber.
pack-priv void	requestMore(long n)

Inherited from rx.Subscriber:: add isUnsubscribed request setProducer unsubscribe

Field Detail

producer	back to summary
private final OperatorOnBackpressureLatest.LatestEmitter<T> producer Hides rx.Subscriber.producer.

Constructor Detail

LatestSubscriber	back to summary
pack-priv LatestSubscriber(OperatorOnBackpressureLatest.LatestEmitter<T> producer)

Method Detail

onCompleted back to summary

onCompleted	back 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

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

onError back to summary

onError	back to summary
public void onError(Throwable e) 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 e:Throwable the exception encountered by the Observable Annotations @Override

public void onError(Throwable e)

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

e:Throwable: the exception encountered by the Observable

Annotations

@Override

onNext back to summary

onNext	back 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

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

onStart	back to summary
public void onStart() Overrides rx.Subscriber.onStart. Doc from rx.Subscriber.onStart. This method is invoked when the Subscriber and Observable have been connected but the Observable has not yet begun to emit items or send notifications to the Subscriber. Override this method to add any useful initialization to your subscription, for instance to initiate backpressure. Annotations @Override

onStart

back to summary

public void onStart()

Overrides rx.Subscriber.onStart.

Doc from rx.Subscriber.onStart.

This method is invoked when the Subscriber and Observable have been connected but the Observable has not yet begun to emit items or send notifications to the Subscriber. Override this method to add any useful initialization to your subscription, for instance to initiate backpressure.

Annotations

@Override

requestMore	back to summary
pack-priv void requestMore(long n)

public final Class OperatorOnBackpressureLatest<T>

Nested and Inner Type Summary

Constructor Summary

Method Summary

Constructor Detail

Method Detail

pack-priv final Class OperatorOnBackpressureLatest.Holder

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

pack-priv final Class OperatorOnBackpressureLatest.LatestEmitter<T>

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

pack-priv final Class OperatorOnBackpressureLatest.LatestSubscriber<T>

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail