Class OperatorWindowWithObservable.SourceSubscriber<T>

    • Field Summary

      Fields 
      Modifier and Type Field Description
      (package private) Subscriber<? super Observable<T>> child  
      (package private) Observer<T> consumer
      Accessed from the serialized part.
      (package private) boolean emitting
      Guarded by guard.
      (package private) java.lang.Object guard  
      (package private) Observable<T> producer
      Accessed from the serialized part.
      (package private) java.util.List<java.lang.Object> queue
      Guarded by guard.
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      (package private) void complete()  
      (package private) void createNewWindow()  
      (package private) void drain​(java.util.List<java.lang.Object> queue)  
      (package private) void emitValue​(T t)  
      (package private) void error​(java.lang.Throwable e)  
      void onCompleted()
      Notifies the Observer that the Observable has finished sending push-based notifications.
      void onError​(java.lang.Throwable e)
      Notifies the Observer that the Observable has experienced an error condition.
      void onNext​(T t)
      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.
      (package private) void replaceSubject()  
      (package private) void replaceWindow()  
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    • Field Detail

      • guard

        final java.lang.Object guard
      • consumer

        Observer<T> consumer
        Accessed from the serialized part.
      • producer

        Observable<T> producer
        Accessed from the serialized part.
      • emitting

        boolean emitting
        Guarded by guard.
      • queue

        java.util.List<java.lang.Object> queue
        Guarded by guard.
    • Method Detail

      • onStart

        public void onStart()
        Description copied from class: Subscriber
        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. Override this method to add any useful initialization to your subscription, for instance to initiate backpressure.
        Overrides:
        onStart in class Subscriber<T>
      • drain

        void drain​(java.util.List<java.lang.Object> queue)
      • replaceSubject

        void replaceSubject()
      • createNewWindow

        void createNewWindow()
      • emitValue

        void emitValue​(T t)
      • onError

        public void onError​(java.lang.Throwable e)
        Description copied from interface: Observer
        Notifies the Observer that the Observable has experienced an error condition.

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

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

        void replaceWindow()
      • complete

        void complete()
      • error

        void error​(java.lang.Throwable e)