# Code coverage report for RxJS/dist/cjs/operators/concatAll.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/ » concatAll.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

    1
    1

    1

    1
    2

    1'use strict';

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

    var _mergeAllSupport = require('./mergeAll-support');

    /**
     * Joins every Observable emitted by the source (an Observable of Observables), in a serial
     * fashion. Subscribing to each one only when the previous one has completed, and merging
     * all of their values into the returned observable.
     *
     * __Warning:__ If the source Observable emits Observables quickly and endlessly, and the
     * Observables it emits generally complete slower than the source emits, you can run into
     * memory issues as the incoming observables collect in an unbounded buffer.
     *
     * @returns {Observable} an observable of values merged from the incoming observables.
     */

    function concatAll() {
      return this.lift(new _mergeAllSupport.MergeAllOperator(1));
    }

    module.exports = exports['default'];