Top Description Inners Fields Constructors Methods
io.reactivex.rxjava3.internal.operators.flowable

public final Class BlockingFlowableLatest<T>

extends Object
implements Iterable<T>
Class Inheritance
All Implemented Interfaces
java.lang.Iterable
Type Parameters
<T>
the value type emitted
Imports
java.util.*, java.util.concurrent.Semaphore, java.util.concurrent.atomic.AtomicReference, org.reactivestreams.Publisher, io.reactivex.rxjava3.core.*, io.reactivex.rxjava3.internal.util.*, io.reactivex.rxjava3.plugins.RxJavaPlugins, io.reactivex.rxjava3.subscribers.DisposableSubscriber
Wait for and iterate over the latest values of the source observable. If the source works faster than the iterator, values may be skipped, but not the onError or onComplete events.

Nested and Inner Type Summary

Modifier and TypeClass and Description
pack-priv static class
BlockingFlowableLatest.LatestSubscriberIterator<T>

Subscriber of source, iterator for output.

Field Summary

Modifier and TypeField and Description
pack-priv final Publisher<? extends T>
source

Constructor Summary

AccessConstructor and Description
public
BlockingFlowableLatest(Publisher<? extends T> source)

Method Summary

Modifier and TypeMethod and Description
public Iterator<T>
iterator()

Implements java.lang.Iterable.iterator.

Returns an iterator over elements of type T.
Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

sourceback to summary
pack-priv final Publisher<? extends T> source

Constructor Detail

BlockingFlowableLatestback to summary
public BlockingFlowableLatest(Publisher<? extends T> source)

Method Detail

iteratorback to summary
public Iterator<T> iterator()

Implements java.lang.Iterable.iterator.

Doc from java.lang.Iterable.iterator.

Returns an iterator over elements of type T.

Returns:Iterator<T>

an Iterator.

Annotations
@Override
io.reactivex.rxjava3.internal.operators.flowable back to summary

pack-priv final Class BlockingFlowableLatest.LatestSubscriberIterator<T>

extends DisposableSubscriber<Notification<T>>
implements Iterator<T>
Class Inheritance
All Implemented Interfaces
java.util.Iterator
Subscriber of source, iterator for output.

Field Summary

Modifier and TypeField and Description
pack-priv Notification<T>
iteratorNotification

pack-priv final Semaphore
notify

pack-priv final AtomicReference<Notification<T>>
value

Constructor Summary

AccessConstructor and Description
pack-priv
LatestSubscriberIterator()

Method Summary

Modifier and TypeMethod and Description
public boolean
hasNext()

Implements java.util.Iterator.hasNext.

Returns true if the iteration has more elements.
public T
next()

Implements java.util.Iterator.next.

Returns the next element in the iteration.
public void
onComplete()

Implements org.reactivestreams.Subscriber.onComplete.

Successful terminal state.
public void
onError(Throwable
the throwable signaled
e)

Implements org.reactivestreams.Subscriber.onError.

Failed terminal state.
public void
onNext(Notification<T>
the element signaled
args)

Implements org.reactivestreams.Subscriber.onNext.

Data notification sent by the Publisher in response to requests to Subscription#request(long).
public void
remove()

Overrides default java.util.Iterator.remove.

Removes from the underlying collection the last element returned by this iterator (optional operation).
Inherited from io.reactivex.rxjava3.subscribers.DisposableSubscriber:
canceldisposeisDisposedonStartonSubscriberequest

Field Detail

iteratorNotificationback to summary
pack-priv Notification<T> iteratorNotification
notifyback to summary
pack-priv final Semaphore notify
valueback to summary
pack-priv final AtomicReference<Notification<T>> value

Constructor Detail

LatestSubscriberIteratorback to summary
pack-priv LatestSubscriberIterator()

Method Detail

hasNextback to summary
public boolean hasNext()

Implements java.util.Iterator.hasNext.

Doc from java.util.Iterator.hasNext.

Returns true if the iteration has more elements. (In other words, returns true if next would return an element rather than throwing an exception.)

Returns:boolean

true if the iteration has more elements

Annotations
@Override
nextback to summary
public T next()

Implements java.util.Iterator.next.

Doc from java.util.Iterator.next.

Returns the next element in the iteration.

Returns:T

the next element in the iteration

Annotations
@Override
onCompleteback to summary
public void onComplete()

Implements org.reactivestreams.Subscriber.onComplete.

Doc from org.reactivestreams.Subscriber.onComplete.

Successful terminal state.

No further events will be sent even if Subscription#request(long) is invoked again.

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

Implements org.reactivestreams.Subscriber.onError.

Doc from org.reactivestreams.Subscriber.onError.

Failed terminal state.

No further events will be sent even if Subscription#request(long) is invoked again.

Parameters
e:Throwable

the throwable signaled

Annotations
@Override
onNextback to summary
public void onNext(Notification<T> args)

Implements org.reactivestreams.Subscriber.onNext.

Doc from org.reactivestreams.Subscriber.onNext.

Data notification sent by the Publisher in response to requests to Subscription#request(long).

Parameters
args:Notification<T>

the element signaled

Annotations
@Override
removeback to summary
public void remove()

Overrides default java.util.Iterator.remove.

Doc from java.util.Iterator.remove.

Removes from the underlying collection the last element returned by this iterator (optional operation). This method can be called only once per call to next.

The behavior of an iterator is unspecified if the underlying collection is modified while the iteration is in progress in any way other than by calling this method, unless an overriding class has specified a concurrent modification policy.

The behavior of an iterator is unspecified if this method is called after a call to the forEachRemaining method.

Annotations
@Override