Class OperatorZip.Zip.InnerSubscriber

    • Field Summary

      Fields 
      Modifier and Type Field Description
      (package private) RxRingBuffer items  
    • Constructor Summary

      Constructors 
      Constructor Description
      InnerSubscriber()  
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      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​(java.lang.Object 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.
      void requestMore​(long n)  
      • Methods inherited from class java.lang.Object

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

      • InnerSubscriber

        InnerSubscriber()
    • 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
      • requestMore

        public void requestMore​(long n)
      • 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
      • onNext

        public void onNext​(java.lang.Object t)
        Description copied from interface: Observer
        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 Observer.onCompleted() or Observer.onError(java.lang.Throwable).

        Parameters:
        t - the item emitted by the Observable