{"size": 796, "ext": "js", "max_stars_repo_path": ".codedoc/node_modules/@connectv/core/dist/es6/pin/spread.js", "max_stars_repo_name": "victorvogelpoel/victorvogelpoel.coding.blog", "max_stars_repo_stars_event_min_datetime": "2020-08-09T06:45:39.000Z", "max_stars_repo_stars_event_max_datetime": "2020-08-09T06:45:39.000Z", "max_issues_repo_path": ".codedoc/node_modules/@connectv/core/dist/es6/pin/spread.js", "max_issues_repo_name": "victorvogelpoel/victorvogelpoel.coding.blog", "max_issues_repo_issues_event_min_datetime": "2021-06-28T20:01:08.000Z", "max_issues_repo_issues_event_max_datetime": "2021-09-20T21:56:48.000Z", "max_forks_repo_path": ".codedoc/node_modules/@connectv/core/dist/es6/pin/spread.js", "max_forks_repo_name": "victorvogelpoel/victorvogelpoel.coding.blog", "max_forks_repo_forks_event_min_datetime": "2020-04-13T14:02:29.000Z", "max_forks_repo_forks_event_max_datetime": "2020-04-13T14:02:29.000Z"}
{"max_stars_count": 1, "max_issues_count": 2, "max_forks_count": 1, "avg_line_length": 29.4814814815, "max_line_length": 96, "alphanum_fraction": 0.6319095477}
import { from, of } from 'rxjs';
import { mergeMap } from 'rxjs/operators';
import { Pipe } from './pipe';
/**
 *
 * Represents [spread](https://connective.dev/docs/spread) pins.
 *
 */
export class Spread extends Pipe {
    constructor() {
        super([
            mergeMap(emission => (emission.value.map) ?
                from(emission.value.map((v) => emission.fork(v))) :
                of(emission))
        ]);
    }
}
/**
 *
 * Creates a [spread](https://connective.dev/docs/spread) pin. A spread pin can be used
 * to spread contents of an array over multiple emissions.
 * [Checkout the docs](https://connective.dev/docs/spread) for examples and further information.
 *
 */
export function spread() { return new Spread(); }
export default spread;
//# sourceMappingURL=spread.js.map