This is RxJS v 4. Find the latest version here

<a id="rxobservableprototypeambrightsource"></a>Rx.Observable.prototype.amb(rightSource)

<a href="#rxobservableprototypeambrightsource">#</a> Ⓢ

Propagates the observable sequence that reacts first.

Arguments

1. rightSource (Observable): Second observable sequence.

Returns

(Observable): An observable sequence that surfaces either of the given sequences, whichever reacted first.

Example

var first = Rx.Observable.timer(300).map(function () { return 'first'; });
var second = Rx.Observable.timer(500).map(function () { return 'second'; });

var source = first.amb(second);

var subscription = source.subscribe(
    function (x) {
        console.log('Next: ' + x);
    },
    function (err) {
        console.log('Error: ' + err);
    },
    function () {
        console.log('Completed');
    });

// => Next: first
// => Completed

Location

File:

• /src/core/linq/observable/ambproto.js

Dist:

• rx.js
• rx.compat.js
• rx.all.js
• rx.all.compat.js
• rx.lite.extras.js

Prerequisites:

• None

NPM Packages:

• rx

NuGet Packages:

• RxJS-All
• RxJS-Main
• RxJS-Lite

Unit Tests:

• /tests/observable/amb.js