Package rx.internal.operators
Class OnSubscribeGroupJoin.ResultManager.LeftObserver
- java.lang.Object
-
- rx.Subscriber<T1>
-
- rx.internal.operators.OnSubscribeGroupJoin.ResultManager.LeftObserver
-
- All Implemented Interfaces:
Observer<T1>,Subscription
- Enclosing class:
- OnSubscribeGroupJoin.ResultManager
final class OnSubscribeGroupJoin.ResultManager.LeftObserver extends Subscriber<T1>
Observe the left source.
-
-
Constructor Summary
Constructors Constructor Description LeftObserver()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidonCompleted()Notifies the Observer that theObservablehas finished sending push-based notifications.voidonError(java.lang.Throwable e)Notifies the Observer that theObservablehas experienced an error condition.voidonNext(T1 args)Provides the Observer with a new item to observe.-
Methods inherited from class rx.Subscriber
add, isUnsubscribed, onStart, request, setProducer, unsubscribe
-
-
-
-
Method Detail
-
onNext
public void onNext(T1 args)
Description copied from interface:ObserverProvides the Observer with a new item to observe.The
Observablemay call this method 0 or more times.The
Observablewill not call this method again after it calls eitherObserver.onCompleted()orObserver.onError(java.lang.Throwable).- Parameters:
args- the item emitted by the Observable
-
onCompleted
public void onCompleted()
Description copied from interface:ObserverNotifies the Observer that theObservablehas finished sending push-based notifications.The
Observablewill not call this method if it callsObserver.onError(java.lang.Throwable).
-
onError
public void onError(java.lang.Throwable e)
Description copied from interface:ObserverNotifies the Observer that theObservablehas experienced an error condition.If the
Observablecalls this method, it will not thereafter callObserver.onNext(T)orObserver.onCompleted().- Parameters:
e- the exception encountered by the Observable
-
-