public static final class BlockingOperatorToIterator.SubscriberIterator<T> extends Subscriber<Notification <? extends T>> implements Iterator <T>
| Constructor and Description |
|---|
SubscriberIterator()
|
| Modifier and Type | Method and Description |
|---|---|
boolean |
hasNext()
|
T |
next()
|
void |
onCompleted()
Notifies the Observer that the
Observable has finished sending push-based notifications.
|
void |
onError(Throwable
Notifies the Observer that the
Observable has experienced an error condition.
|
void |
onNext(Notification
Provides the Observer with a new item to observe.
|
void |
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.
|
void |
remove()
|
add, isUnsubscribed, request, setProducer, unsubscribeclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitforEachRemainingpublic void onStart()
Subscriber
public void onCompleted()
Observer
Observable has finished sending push-based notifications.
The Observable will not call this method if it calls Observer.
public void onError(Throwablee)
Observer
Observable has experienced an error condition.
If the Observable calls this method, it will not thereafter call Observer or Observer.
onError in interface
Observer<Notification<? extends T>>
e - the exception encountered by the Observable
public void onNext(Notification<? extends T> args)
Observer
The Observable may call this method 0 or more times.
The Observable will not call this method again after it calls either Observer or Observer.
onNext in interface
Observer<Notification<? extends T>>
args - the item emitted by the Observable
public boolean hasNext()
public T next()
public void remove()