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 multiple Observables, 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 of `Observable`s, propagates the one that first emits an item.
`static <T> Observable.OnSubscribe<T>`	`amb(Observable<? extends T> o1, Observable<? extends T> o2)`	Given two `Observable`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 three `Observable`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 four `Observable`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 five `Observable`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 six `Observable`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 seven `Observable`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 eight `Observable`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 nine `Observable`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)`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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

call

public void call(Subscriber<? super T> subscriber)

Specified by:: call in interface Action1<T>

unsubscribeAmbSubscribers

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

Modifier and Type	Class	Description
`(package private) static class`	`OnSubscribeAmb.AmbSubscriber<T>`
`(package private) static class`	`OnSubscribeAmb.Selection<T>`

Class OnSubscribeAmb<T>

Nested Class Summary

Field Summary

Constructor Summary