Class OperatorWindowWithTime.ExactSubscriber

    • 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

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

        boolean replaceSubject()
      • emitValue

        boolean 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
      • error

        void error​(java.lang.Throwable e)
      • complete

        void complete()
      • scheduleExact

        void scheduleExact()
      • nextWindow

        void nextWindow()