forkJoin

Runs all observable sequences in parallel and collect their last elements.
Arguments
args
(Arguments
|Array
): An array or arguments of Observable sequences or Promises to collect the last elements for.resultSelector
: (Function
) - The result selector from all the values produced. If not specified,forkJoin
will return the results as an array.
Returns
(Observable
): An observable sequence with an array collecting the last elements of all the input sequences or the result of the result selector if specified.
/* Using observables and Promises */
var source = Rx.Observable.forkJoin(
Rx.Observable.return(42),
Rx.Observable.range(0, 10),
Rx.Observable.fromArray([1,2,3]),
RSVP.Promise.resolve(56)
);
var subscription = source.subscribe(
x => console.log(`onNext: ${x}`),
e => console.log(`onError: ${e}`),
() => console.log('onCompleted'));
// => onNext: [42, 9, 3, 56]
// => onCompleted
Example
Last updated
Was this helpful?