Class FlowableAmb.AmbCoordinator<T>

  • All Implemented Interfaces:
    org.reactivestreams.Subscription
    Enclosing class:
    FlowableAmb<T>

    static final class FlowableAmb.AmbCoordinator<T>
    extends java.lang.Object
    implements org.reactivestreams.Subscription
    • Constructor Summary

      Constructors 
      Constructor Description
      AmbCoordinator​(org.reactivestreams.Subscriber<? super T> actual, int count)  
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void cancel()  
      void request​(long n)  
      void subscribe​(org.reactivestreams.Publisher<? extends T>[] sources)  
      boolean win​(int index)  
      • Methods inherited from class java.lang.Object

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

      • downstream

        final org.reactivestreams.Subscriber<? super T> downstream
      • winner

        final java.util.concurrent.atomic.AtomicInteger winner
    • Constructor Detail

      • AmbCoordinator

        AmbCoordinator​(org.reactivestreams.Subscriber<? super T> actual,
                       int count)
    • Method Detail

      • subscribe

        public void subscribe​(org.reactivestreams.Publisher<? extends T>[] sources)
      • request

        public void request​(long n)
        Specified by:
        request in interface org.reactivestreams.Subscription
      • win

        public boolean win​(int index)
      • cancel

        public void cancel()
        Specified by:
        cancel in interface org.reactivestreams.Subscription