# Code coverage report for RxJS/dist/cjs/operators/combineAll.js

## Statements: 100% (6 / 6) Branches: 100% (0 / 0) Functions: 100% (1 / 1) Lines: 100% (6 / 6) Ignored: none

All files » RxJS/dist/cjs/operators/ » combineAll.js

    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    15
    16
    17
    18
    19
    20
    21
    22
    23
    24
    25

    1
    1

    1

    1
    2

    1'use strict';

    exports.__esModule = true;
    exports['default'] = combineAll;

    var _combineLatestSupport = require('./combineLatest-support');

    /**
     * Takes an Observable of Observables, and collects all observables from it. Once the outer observable
     * completes, it subscribes to all collected observables and "combines" their values, such that:
     *  - every time an observable emits, the returned observable emits
     *  - when the returned observable emits, it emits all of the most recent values by:
     *    - if a `project` function is provided, it is called with each recent value from each observable in whatever order they arrived,
     *      and the result of the `project` function is what is emitted by the returned observable
     *    - if there is no `project` function, an array of all of the most recent values is emitted by the returned observable.
     * @param {function} [project] an optional function to map the most recent values from each observable into a new result. Takes each of the
     *   most recent values from each collected observable as arguments, in order.
     * @returns {Observable} an observable of projected results or arrays of recent values.
     */

    function combineAll(project) {
      return this.lift(new _combineLatestSupport.CombineLatestOperator(project));
    }

    module.exports = exports['default'];