Package rx

Interface Observer<T>

Type Parameters:
T - the type of item the Observer expects to observe
All Known Subinterfaces:
AsyncEmitter<T>
All Known Implementing Classes:
ActionNotificationObserver, ActionSubscriber, AsyncOnSubscribe.AsyncOuterManager, AsyncOnSubscribe.UnicastSubject, AsyncSubject, BehaviorSubject, BlockingOperatorLatest.LatestObserverIterator, BlockingOperatorMostRecent.MostRecentObserver, BlockingOperatorNext.NextObserver, BlockingOperatorToIterator.SubscriberIterator, BufferUntilSubscriber, CachedObservable.CacheState, CompletableOnSubscribeConcat.CompletableConcatSubscriber, CompletableOnSubscribeMerge.CompletableMergeSubscriber, DeferredScalarSubscriber, ObserverSubscriber, OnSubscribeAmb.AmbSubscriber, OnSubscribeCollect.CollectSubscriber, OnSubscribeCombineLatest.CombinerSubscriber, OnSubscribeConcatMap.ConcatMapInnerSubscriber, OnSubscribeConcatMap.ConcatMapSubscriber, OnSubscribeDetach.DetachSubscriber, OnSubscribeFilter.FilterSubscriber, OnSubscribeFlattenIterable.FlattenIterableSubscriber, OnSubscribeFromAsync.BaseAsyncEmitter, OnSubscribeFromAsync.BufferAsyncEmitter, OnSubscribeFromAsync.DropAsyncEmitter, OnSubscribeFromAsync.ErrorAsyncEmitter, OnSubscribeFromAsync.LatestAsyncEmitter, OnSubscribeFromAsync.NoneAsyncEmitter, OnSubscribeFromAsync.NoOverflowBaseAsyncEmitter, OnSubscribeGroupJoin.ResultManager.LeftDurationObserver, OnSubscribeGroupJoin.ResultManager.LeftObserver, OnSubscribeGroupJoin.ResultManager.RightDurationObserver, OnSubscribeGroupJoin.ResultManager.RightObserver, OnSubscribeGroupJoin.WindowObservableFunc.WindowSubscriber, OnSubscribeJoin.ResultSink.LeftSubscriber, OnSubscribeJoin.ResultSink.LeftSubscriber.LeftDurationSubscriber, OnSubscribeJoin.ResultSink.RightSubscriber, OnSubscribeJoin.ResultSink.RightSubscriber.RightDurationSubscriber, OnSubscribeMap.MapSubscriber, OnSubscribeOnAssembly.OnAssemblySubscriber, OnSubscribePublishMulticast, OnSubscribePublishMulticast.ParentSubscriber, OnSubscribeReduce.ReduceSubscriber, OnSubscribeReduceSeed.ReduceSeedSubscriber, OnSubscribeTakeLastOne.TakeLastOneSubscriber, OperatorBufferWithSingleObservable.BufferingSubscriber, OperatorBufferWithSize.BufferExact, OperatorBufferWithSize.BufferOverlap, OperatorBufferWithSize.BufferSkip, OperatorBufferWithStartEndObservable.BufferingSubscriber, OperatorBufferWithTime.ExactSubscriber, OperatorBufferWithTime.InexactSubscriber, OperatorCast.CastSubscriber, OperatorDoOnRequest.ParentSubscriber, OperatorEagerConcatMap.EagerInnerSubscriber, OperatorEagerConcatMap.EagerOuterSubscriber, OperatorGroupBy.GroupBySubscriber, OperatorMapNotification.MapNotificationSubscriber, OperatorMapPair.MapPairSubscriber, OperatorMaterialize.ParentSubscriber, OperatorMerge.InnerSubscriber, OperatorMerge.MergeSubscriber, OperatorObserveOn.ObserveOnSubscriber, OperatorOnBackpressureBuffer.BufferSubscriber, OperatorOnBackpressureLatest.LatestEmitter, OperatorOnBackpressureLatest.LatestSubscriber, OperatorPublish.PublishSubscriber, OperatorReplay.ReplaySubscriber, OperatorRetryWithPredicate.SourceSubscriber, OperatorSampleWithTime.SamplerSubscriber, OperatorScan.InitialProducer, OperatorSingle.ParentSubscriber, OperatorSwitch.InnerSubscriber, OperatorSwitch.SwitchSubscriber, OperatorSwitchIfEmpty.AlternateSubscriber, OperatorSwitchIfEmpty.ParentSubscriber, OperatorTakeLast.TakeLastSubscriber, OperatorTakeLastTimed.TakeLastTimedSubscriber, OperatorTakeTimed.TakeSubscriber, OperatorTakeUntilPredicate.ParentSubscriber, OperatorTimeoutBase.TimeoutSubscriber, OperatorWindowWithObservable.BoundarySubscriber, OperatorWindowWithObservable.SourceSubscriber, OperatorWindowWithObservableFactory.BoundarySubscriber, OperatorWindowWithObservableFactory.SourceSubscriber, OperatorWindowWithSize.WindowExact, OperatorWindowWithSize.WindowOverlap, OperatorWindowWithSize.WindowSkip, OperatorWindowWithStartEndObservable.SourceSubscriber, OperatorWindowWithTime.ExactSubscriber, OperatorWindowWithTime.InexactSubscriber, OperatorWithLatestFromMany.WithLatestMainSubscriber, OperatorWithLatestFromMany.WithLatestOtherSubscriber, OperatorZip.Zip.InnerSubscriber, OperatorZip.ZipSubscriber, ProducerObserverArbiter, PublishSubject, QueuedProducer, ReplaySubject, ReplaySubject.ReplayState, SafeSubscriber, SerializedObserver, SerializedSubject, SerializedSubscriber, Subject, SubjectSubscriptionManager.SubjectObserver, Subscriber, SyncOnSubscribe.SubscriptionProducer, TestObserver, TestSubject, TestSubscriber, UnicastSubject, UnicastSubject.State

public interface Observer<T>
Provides a mechanism for receiving push-based notifications.

After an Observer calls an Observable's subscribe method, the Observable calls the Observer's onNext(T) method to provide notifications. A well-behaved Observable will call an Observer's onCompleted() method exactly once or the Observer's onError(java.lang.Throwable) method exactly once.

See Also:
  • Method Summary

    Modifier and Type
    Method
    Description
    void
    Notifies the Observer that the Observable has finished sending push-based notifications.
    void
    Notifies the Observer that the Observable has experienced an error condition.
    void
    onNext(T t)
    Provides the Observer with a new item to observe.
  • Method Details

    • onCompleted

      void onCompleted()
      Notifies the Observer that the Observable has finished sending push-based notifications.

      The Observable will not call this method if it calls onError(java.lang.Throwable).

    • onError

      void onError(Throwable e)
      Notifies the Observer that the Observable has experienced an error condition.

      If the Observable calls this method, it will not thereafter call onNext(T) or onCompleted().

      Parameters:
      e - the exception encountered by the Observable
    • onNext

      void onNext(T t)
      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(java.lang.Throwable).

      Parameters:
      t - the item emitted by the Observable