Class OnSubscribeAmb<T>

    • Field Detail

      • sources

        final java.lang.Iterable<? extends Observable<? extends T>> sources
    • Constructor Detail

      • OnSubscribeAmb

        private OnSubscribeAmb​(java.lang.Iterable<? extends Observable<? extends T>> sources)
    • Method Detail

      • amb

        public static <T> Observable.OnSubscribe<T> amb​(Observable<? extends T> o1,
                                                        Observable<? extends T> o2)
        Given two Observables, propagates the one that first emits an item.
        Type Parameters:
        T - the common value base type
        Parameters:
        o1 - the first Observable
        o2 - the second Observable
        Returns:
        an Observable that mirrors the one of the source Observables that was first to emit an item
      • amb

        public static <T> Observable.OnSubscribe<T> amb​(Observable<? extends T> o1,
                                                        Observable<? extends T> o2,
                                                        Observable<? extends T> o3)
        Given three Observables, propagates the one that first emits an item.
        Type Parameters:
        T - the common value base type
        Parameters:
        o1 - the first Observable
        o2 - the second Observable
        o3 - the third Observable
        Returns:
        an Observable that mirrors the one of the source Observables that was first to emit an item
      • amb

        public static <T> Observable.OnSubscribe<T> amb​(Observable<? extends T> o1,
                                                        Observable<? extends T> o2,
                                                        Observable<? extends T> o3,
                                                        Observable<? extends T> o4)
        Given four Observables, propagates the one that first emits an item.
        Type Parameters:
        T - the common value base type
        Parameters:
        o1 - the first Observable
        o2 - the second Observable
        o3 - the third Observable
        o4 - the fourth Observable
        Returns:
        an Observable that mirrors the one of the source Observables that was first to emit an item
      • amb

        public static <T> Observable.OnSubscribe<T> amb​(Observable<? extends T> o1,
                                                        Observable<? extends T> o2,
                                                        Observable<? extends T> o3,
                                                        Observable<? extends T> o4,
                                                        Observable<? extends T> o5)
        Given five Observables, propagates the one that first emits an item.
        Type Parameters:
        T - the common value base type
        Parameters:
        o1 - the first Observable
        o2 - the second Observable
        o3 - the third Observable
        o4 - the fourth Observable
        o5 - the fifth Observable
        Returns:
        an Observable that mirrors the one of the source Observables that was first to emit an item
      • amb

        public static <T> Observable.OnSubscribe<T> amb​(Observable<? extends T> o1,
                                                        Observable<? extends T> o2,
                                                        Observable<? extends T> o3,
                                                        Observable<? extends T> o4,
                                                        Observable<? extends T> o5,
                                                        Observable<? extends T> o6)
        Given six Observables, propagates the one that first emits an item.
        Type Parameters:
        T - the common value base type
        Parameters:
        o1 - the first Observable
        o2 - the second Observable
        o3 - the third Observable
        o4 - the fourth Observable
        o5 - the fifth Observable
        o6 - the sixth Observable
        Returns:
        an Observable that mirrors the one of the source Observables that was first to emit an item
      • amb

        public static <T> Observable.OnSubscribe<T> amb​(Observable<? extends T> o1,
                                                        Observable<? extends T> o2,
                                                        Observable<? extends T> o3,
                                                        Observable<? extends T> o4,
                                                        Observable<? extends T> o5,
                                                        Observable<? extends T> o6,
                                                        Observable<? extends T> o7)
        Given seven Observables, propagates the one that first emits an item.
        Type Parameters:
        T - the common value base type
        Parameters:
        o1 - the first Observable
        o2 - the second Observable
        o3 - the third Observable
        o4 - the fourth Observable
        o5 - the fifth Observable
        o6 - the sixth Observable
        o7 - the seventh Observable
        Returns:
        an Observable that mirrors the one of the source Observables that was first to emit an item
      • amb

        public static <T> Observable.OnSubscribe<T> amb​(Observable<? extends T> o1,
                                                        Observable<? extends T> o2,
                                                        Observable<? extends T> o3,
                                                        Observable<? extends T> o4,
                                                        Observable<? extends T> o5,
                                                        Observable<? extends T> o6,
                                                        Observable<? extends T> o7,
                                                        Observable<? extends T> o8)
        Given eight Observables, propagates the one that first emits an item.
        Type Parameters:
        T - the common value base type
        Parameters:
        o1 - the first Observable
        o2 - the second Observable
        o3 - the third Observable
        o4 - the fourth Observable
        o5 - the fifth Observable
        o6 - the sixth Observable
        o7 - the seventh Observable
        o8 - the eighth Observable
        Returns:
        an Observable that mirrors the one of the source Observables that was first to emit an item
      • amb

        public static <T> Observable.OnSubscribe<T> amb​(Observable<? extends T> o1,
                                                        Observable<? extends T> o2,
                                                        Observable<? extends T> o3,
                                                        Observable<? extends T> o4,
                                                        Observable<? extends T> o5,
                                                        Observable<? extends T> o6,
                                                        Observable<? extends T> o7,
                                                        Observable<? extends T> o8,
                                                        Observable<? extends T> o9)
        Given nine Observables, propagates the one that first emits an item.
        Type Parameters:
        T - the common value base type
        Parameters:
        o1 - the first Observable
        o2 - the second Observable
        o3 - the third Observable
        o4 - the fourth Observable
        o5 - the fifth Observable
        o6 - the sixth Observable
        o7 - the seventh Observable
        o8 - the eighth Observable
        o9 - the ninth Observable
        Returns:
        an Observable that mirrors the one of the source Observables that was first to emit an item
      • amb

        public static <T> Observable.OnSubscribe<T> amb​(java.lang.Iterable<? extends Observable<? extends T>> sources)
        Given a set of Observables, propagates the one that first emits an item.
        Type Parameters:
        T - the common value base type
        Parameters:
        sources - an Iterable of Observables
        Returns:
        an Observable that mirrors the one of the Observables in sources that was the first to emit an item
      • unsubscribeAmbSubscribers

        static <T> void unsubscribeAmbSubscribers​(java.util.Collection<OnSubscribeAmb.AmbSubscriber<T>> ambSubscribers)