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 e)
Notifies the Observer that the
Observable has experienced an error condition. |
void |
onNext(Notification<? extends T> args)
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, unsubscribe
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
forEachRemaining
public void onStart()
Subscriber
onStart
in class Subscriber<Notification<? extends T>>
public void onCompleted()
Observer
Observable
has finished sending push-based notifications.
The Observable
will not call this method if it calls Observer.onError(java.lang.Throwable)
.
onCompleted
in interface Observer<Notification<? extends T>>
public void onError(Throwable e)
Observer
Observable
has experienced an error condition.
If the Observable
calls this method, it will not thereafter call Observer.onNext(T)
or
Observer.onCompleted()
.
onError
in interface Observer<Notification<? extends T>>
e
- the exception encountered by the Observablepublic 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.onCompleted()
or
Observer.onError(java.lang.Throwable)
.
onNext
in interface Observer<Notification<? extends T>>
args
- the item emitted by the ObservableCopyright © 2017. All rights reserved.