Class OnSubscribeFlattenIterable.FlattenIterableSubscriber<T,​R>

    • Field Summary

      Fields 
      Modifier and Type Field Description
      (package private) java.util.Iterator<? extends R> active  
      (package private) Subscriber<? super R> actual  
      (package private) boolean done  
      (package private) java.util.concurrent.atomic.AtomicReference<java.lang.Throwable> error  
      (package private) long limit  
      (package private) Func1<? super T,​? extends java.lang.Iterable<? extends R>> mapper  
      (package private) NotificationLite<T> nl  
      (package private) long produced  
      (package private) java.util.Queue<java.lang.Object> queue  
      (package private) java.util.concurrent.atomic.AtomicLong requested  
      (package private) java.util.concurrent.atomic.AtomicInteger wip  
    • Field Detail

      • mapper

        final Func1<? super T,​? extends java.lang.Iterable<? extends R>> mapper
      • limit

        final long limit
      • queue

        final java.util.Queue<java.lang.Object> queue
      • error

        final java.util.concurrent.atomic.AtomicReference<java.lang.Throwable> error
      • requested

        final java.util.concurrent.atomic.AtomicLong requested
      • wip

        final java.util.concurrent.atomic.AtomicInteger wip
      • done

        volatile boolean done
      • produced

        long produced
      • active

        java.util.Iterator<? extends R> active
    • Constructor Detail

      • FlattenIterableSubscriber

        public FlattenIterableSubscriber​(Subscriber<? super R> actual,
                                         Func1<? super T,​? extends java.lang.Iterable<? extends R>> mapper,
                                         int prefetch)
    • Method Detail

      • 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
      • requestMore

        void requestMore​(long n)
      • drain

        void drain()
      • checkTerminated

        boolean checkTerminated​(boolean d,
                                boolean empty,
                                Subscriber<?> a,
                                java.util.Queue<?> q)