| 1 | "use strict";
|
| 2 | Object.defineProperty(exports, "__esModule", { value: true });
|
| 3 | exports.create = void 0;
|
| 4 | var util_value_1 = require("@platform/util.value");
|
| 5 | var operators_1 = require("rxjs/operators");
|
| 6 | function create(args) {
|
| 7 | var $ = args.event$.pipe(operators_1.takeUntil(args.until$));
|
| 8 | var changed$ = $.pipe(operators_1.filter(function (e) { return e.type === 'TreeState/changed'; }), operators_1.map(function (e) { return e.payload; }), operators_1.share());
|
| 9 | var patched$ = $.pipe(operators_1.filter(function (e) { return e.type === 'TreeState/patched'; }), operators_1.map(function (e) { return e.payload; }), operators_1.share());
|
| 10 | var childAdded$ = $.pipe(operators_1.filter(function (e) { return e.type === 'TreeState/child/added'; }), operators_1.map(function (e) { return e.payload; }), operators_1.share());
|
| 11 | var childRemoved$ = $.pipe(operators_1.filter(function (e) { return e.type === 'TreeState/child/removed'; }), operators_1.map(function (e) { return e.payload; }), operators_1.share());
|
| 12 | return {
|
| 13 | $: $,
|
| 14 | changed$: changed$,
|
| 15 | patched$: patched$,
|
| 16 | childAdded$: childAdded$,
|
| 17 | childRemoved$: childRemoved$,
|
| 18 | payload: function (type) { return util_value_1.rx.payload($, type); },
|
| 19 | };
|
| 20 | }
|
| 21 | exports.create = create;
|