Package rx.internal.operators
Class OnSubscribeAmb<T>
java.lang.Object
rx.internal.operators.OnSubscribeAmb<T>
- Type Parameters:
T
- the value type
- All Implemented Interfaces:
Action
,Action1<Subscriber<? super T>>
,Function
,Observable.OnSubscribe<T>
Given multiple
Observable
s, propagates the one that first emits an item.-
Nested Class Summary
Nested ClassesModifier and TypeClassDescription(package private) static final class
(package private) static final class
-
Field Summary
FieldsModifier and TypeFieldDescription(package private) final Iterable
<? extends Observable<? extends T>> -
Constructor Summary
ConstructorsModifierConstructorDescriptionprivate
OnSubscribeAmb
(Iterable<? extends Observable<? extends T>> sources) -
Method Summary
Modifier and TypeMethodDescriptionstatic <T> Observable.OnSubscribe
<T> amb
(Iterable<? extends Observable<? extends T>> sources) Given a set ofObservable
s, propagates the one that first emits an item.static <T> Observable.OnSubscribe
<T> amb
(Observable<? extends T> o1, Observable<? extends T> o2) Given twoObservable
s, propagates the one that first emits an item.static <T> Observable.OnSubscribe
<T> amb
(Observable<? extends T> o1, Observable<? extends T> o2, Observable<? extends T> o3) Given threeObservable
s, propagates the one that first emits an item.static <T> Observable.OnSubscribe
<T> amb
(Observable<? extends T> o1, Observable<? extends T> o2, Observable<? extends T> o3, Observable<? extends T> o4) Given fourObservable
s, propagates the one that first emits an item.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 fiveObservable
s, propagates the one that first emits an item.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 sixObservable
s, propagates the one that first emits an item.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 sevenObservable
s, propagates the one that first emits an item.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 eightObservable
s, propagates the one that first emits an item.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 nineObservable
s, propagates the one that first emits an item.void
call
(Subscriber<? super T> subscriber) (package private) static <T> void
unsubscribeAmbSubscribers
(Collection<OnSubscribeAmb.AmbSubscriber<T>> ambSubscribers)
-
Field Details
-
sources
-
-
Constructor Details
-
OnSubscribeAmb
-
-
Method Details
-
amb
public static <T> Observable.OnSubscribe<T> amb(Observable<? extends T> o1, Observable<? extends T> o2) Given twoObservable
s, propagates the one that first emits an item.- Type Parameters:
T
- the common value base type- Parameters:
o1
- the firstObservable
o2
- the secondObservable
- Returns:
- an
Observable
that mirrors the one of the sourceObservable
s 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 threeObservable
s, propagates the one that first emits an item.- Type Parameters:
T
- the common value base type- Parameters:
o1
- the firstObservable
o2
- the secondObservable
o3
- the thirdObservable
- Returns:
- an
Observable
that mirrors the one of the sourceObservable
s 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 fourObservable
s, propagates the one that first emits an item.- Type Parameters:
T
- the common value base type- Parameters:
o1
- the firstObservable
o2
- the secondObservable
o3
- the thirdObservable
o4
- the fourthObservable
- Returns:
- an
Observable
that mirrors the one of the sourceObservable
s 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 fiveObservable
s, propagates the one that first emits an item.- Type Parameters:
T
- the common value base type- Parameters:
o1
- the firstObservable
o2
- the secondObservable
o3
- the thirdObservable
o4
- the fourthObservable
o5
- the fifthObservable
- Returns:
- an
Observable
that mirrors the one of the sourceObservable
s 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 sixObservable
s, propagates the one that first emits an item.- Type Parameters:
T
- the common value base type- Parameters:
o1
- the firstObservable
o2
- the secondObservable
o3
- the thirdObservable
o4
- the fourthObservable
o5
- the fifthObservable
o6
- the sixthObservable
- Returns:
- an
Observable
that mirrors the one of the sourceObservable
s 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 sevenObservable
s, propagates the one that first emits an item.- Type Parameters:
T
- the common value base type- Parameters:
o1
- the firstObservable
o2
- the secondObservable
o3
- the thirdObservable
o4
- the fourthObservable
o5
- the fifthObservable
o6
- the sixthObservable
o7
- the seventhObservable
- Returns:
- an
Observable
that mirrors the one of the sourceObservable
s 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 eightObservable
s, propagates the one that first emits an item.- Type Parameters:
T
- the common value base type- Parameters:
o1
- the firstObservable
o2
- the secondObservable
o3
- the thirdObservable
o4
- the fourthObservable
o5
- the fifthObservable
o6
- the sixthObservable
o7
- the seventhObservable
o8
- the eighthObservable
- Returns:
- an
Observable
that mirrors the one of the sourceObservable
s 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 nineObservable
s, propagates the one that first emits an item.- Type Parameters:
T
- the common value base type- Parameters:
o1
- the firstObservable
o2
- the secondObservable
o3
- the thirdObservable
o4
- the fourthObservable
o5
- the fifthObservable
o6
- the sixthObservable
o7
- the seventhObservable
o8
- the eighthObservable
o9
- the ninthObservable
- Returns:
- an
Observable
that mirrors the one of the sourceObservable
s that was first to emit an item
-
amb
public static <T> Observable.OnSubscribe<T> amb(Iterable<? extends Observable<? extends T>> sources) Given a set ofObservable
s, propagates the one that first emits an item.- Type Parameters:
T
- the common value base type- Parameters:
sources
- anIterable
ofObservable
s- Returns:
- an
Observable
that mirrors the one of theObservable
s insources
that was the first to emit an item
-
call
-
unsubscribeAmbSubscribers
static <T> void unsubscribeAmbSubscribers(Collection<OnSubscribeAmb.AmbSubscriber<T>> ambSubscribers)
-