amb.md

Rx.Observable.amb(...args)

{% if book.isPdf==true %}

{% else %}

{% endif %}

Propagates the observable sequence or Promise that reacts first. "amb" stands for ambiguous.

Arguments

1. args (Array|arguments): Observable sources or Promises competing to react first either as an array or arguments.

Returns

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

Example

{% if book.isPdf==true %}

Using Observable sequences

var source = Rx.Observable.amb(
    Rx.Observable.timer(500).select(() => 'foo'),
    Rx.Observable.timer(200).select(() => 'bar')
);

var subscription = source.subscribe(
  x => console.log(`onNext: ${x}`),
  e => console.log(`onError: ${e}`),
  () => console.log('onCompleted'));

// => onNext: bar
// => onCompleted 

Using Promises and Observables

var source = Rx.Observable.amb(
    RSVP.Promise.resolve('foo'),
    Rx.Observable.timer(200).select(() => 'bar')
);

var subscription = source.subscribe(
  x => console.log(`onNext: ${x}`),
  e => console.log(`onError: ${e}`),
  () => console.log('onCompleted'));

// => onNext: foo
// => onCompleted

{% else %}

Using Observable sequences

Using Promises and Observables

{% endif %}