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>
public final class OnSubscribeAmb<T> extends java.lang.Object implements Observable.OnSubscribe<T>
Given multipleObservable
s, propagates the one that first emits an item.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description (package private) static class
OnSubscribeAmb.AmbSubscriber<T>
(package private) static class
OnSubscribeAmb.Selection<T>
-
Field Summary
Fields Modifier and Type Field Description (package private) java.lang.Iterable<? extends Observable<? extends T>>
sources
-
Constructor Summary
Constructors Modifier Constructor Description private
OnSubscribeAmb(java.lang.Iterable<? extends Observable<? extends T>> sources)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static <T> Observable.OnSubscribe<T>
amb(java.lang.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(java.util.Collection<OnSubscribeAmb.AmbSubscriber<T>> ambSubscribers)
-
-
-
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 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(java.lang.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
public void call(Subscriber<? super T> subscriber)
-
unsubscribeAmbSubscribers
static <T> void unsubscribeAmbSubscribers(java.util.Collection<OnSubscribeAmb.AmbSubscriber<T>> ambSubscribers)
-
-