Class FlowableJoin.JoinSubscription<TLeft,​TRight,​TLeftEnd,​TRightEnd,​R>

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void cancel()  
      (package private) void cancelAll()  
      (package private) void drain()  
      (package private) void errorAll​(org.reactivestreams.Subscriber<?> a)  
      (package private) void fail​(java.lang.Throwable exc, org.reactivestreams.Subscriber<?> a, SimpleQueue<?> q)  
      void innerClose​(boolean isLeft, FlowableGroupJoin.LeftRightEndSubscriber index)  
      void innerCloseError​(java.lang.Throwable ex)  
      void innerComplete​(FlowableGroupJoin.LeftRightSubscriber sender)  
      void innerError​(java.lang.Throwable ex)  
      void innerValue​(boolean isLeft, java.lang.Object o)  
      void request​(long n)  
      • Methods inherited from class java.util.concurrent.atomic.AtomicInteger

        accumulateAndGet, addAndGet, compareAndExchange, compareAndExchangeAcquire, compareAndExchangeRelease, compareAndSet, decrementAndGet, doubleValue, floatValue, get, getAcquire, getAndAccumulate, getAndAdd, getAndDecrement, getAndIncrement, getAndSet, getAndUpdate, getOpaque, getPlain, incrementAndGet, intValue, lazySet, longValue, set, setOpaque, setPlain, setRelease, toString, updateAndGet, weakCompareAndSet, weakCompareAndSetAcquire, weakCompareAndSetPlain, weakCompareAndSetRelease, weakCompareAndSetVolatile
      • Methods inherited from class java.lang.Number

        byteValue, shortValue
      • Methods inherited from class java.lang.Object

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

      • downstream

        final org.reactivestreams.Subscriber<? super R> downstream
      • requested

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

        final java.util.Map<java.lang.Integer,​TLeft> lefts
      • rights

        final java.util.Map<java.lang.Integer,​TRight> rights
      • error

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

        final java.util.concurrent.atomic.AtomicInteger active
      • leftIndex

        int leftIndex
      • rightIndex

        int rightIndex
      • cancelled

        volatile boolean cancelled
      • LEFT_VALUE

        static final java.lang.Integer LEFT_VALUE
      • RIGHT_VALUE

        static final java.lang.Integer RIGHT_VALUE
      • LEFT_CLOSE

        static final java.lang.Integer LEFT_CLOSE
      • RIGHT_CLOSE

        static final java.lang.Integer RIGHT_CLOSE
    • Constructor Detail

      • JoinSubscription

        JoinSubscription​(org.reactivestreams.Subscriber<? super R> actual,
                         Function<? super TLeft,​? extends org.reactivestreams.Publisher<TLeftEnd>> leftEnd,
                         Function<? super TRight,​? extends org.reactivestreams.Publisher<TRightEnd>> rightEnd,
                         BiFunction<? super TLeft,​? super TRight,​? extends R> resultSelector)