store.class.js 6.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125
  1. /**
  2. * @fileoverview added by tsickle
  3. * @suppress {checkTypes,extraRequire,missingOverride,missingReturn,unusedPrivateMembers,uselessCode} checked by tsc
  4. */
  5. import * as tslib_1 from "tslib";
  6. /**
  7. * @copyright ngrx
  8. */
  9. import { Observable } from 'rxjs';
  10. import { distinctUntilChanged, map } from 'rxjs/operators';
  11. /**
  12. * @template T
  13. */
  14. var /**
  15. * @template T
  16. */
  17. MiniStore = /** @class */ (function (_super) {
  18. tslib_1.__extends(MiniStore, _super);
  19. function MiniStore(_dispatcher, _reducer,
  20. /* tslint:disable-next-line: no-any */
  21. state$) {
  22. var _this = _super.call(this) || this;
  23. _this._dispatcher = _dispatcher;
  24. _this._reducer = _reducer;
  25. /* tslint:disable-next-line: deprecation */
  26. _this.source = state$;
  27. return _this;
  28. }
  29. /**
  30. * @template R
  31. * @param {?} pathOrMapFn
  32. * @return {?}
  33. */
  34. MiniStore.prototype.select = /**
  35. * @template R
  36. * @param {?} pathOrMapFn
  37. * @return {?}
  38. */
  39. function (pathOrMapFn) {
  40. /* tslint:disable-next-line: deprecation */
  41. /** @type {?} */
  42. var mapped$ = this.source.pipe(map(pathOrMapFn));
  43. return mapped$.pipe(distinctUntilChanged());
  44. };
  45. /**
  46. * @template R
  47. * @param {?} operator
  48. * @return {?}
  49. */
  50. MiniStore.prototype.lift = /**
  51. * @template R
  52. * @param {?} operator
  53. * @return {?}
  54. */
  55. function (operator) {
  56. /** @type {?} */
  57. var store = new MiniStore(this._dispatcher, this._reducer, this);
  58. /* tslint:disable-next-line: deprecation */
  59. store.operator = operator;
  60. return store;
  61. };
  62. /**
  63. * @param {?} action
  64. * @return {?}
  65. */
  66. MiniStore.prototype.dispatch = /**
  67. * @param {?} action
  68. * @return {?}
  69. */
  70. function (action) {
  71. this._dispatcher.next(action);
  72. };
  73. /**
  74. * @param {?} action
  75. * @return {?}
  76. */
  77. MiniStore.prototype.next = /**
  78. * @param {?} action
  79. * @return {?}
  80. */
  81. function (action) {
  82. this._dispatcher.next(action);
  83. };
  84. /* tslint:disable-next-line: no-any */
  85. /* tslint:disable-next-line: no-any */
  86. /**
  87. * @param {?} err
  88. * @return {?}
  89. */
  90. MiniStore.prototype.error = /* tslint:disable-next-line: no-any */
  91. /**
  92. * @param {?} err
  93. * @return {?}
  94. */
  95. function (err) {
  96. this._dispatcher.error(err);
  97. };
  98. /**
  99. * @return {?}
  100. */
  101. MiniStore.prototype.complete = /**
  102. * @return {?}
  103. */
  104. function () {
  105. /*noop*/
  106. };
  107. return MiniStore;
  108. }(Observable));
  109. /**
  110. * @template T
  111. */
  112. export { MiniStore };
  113. if (false) {
  114. /**
  115. * @type {?}
  116. * @private
  117. */
  118. MiniStore.prototype._dispatcher;
  119. /**
  120. * @type {?}
  121. * @private
  122. */
  123. MiniStore.prototype._reducer;
  124. }
  125. //# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoic3RvcmUuY2xhc3MuanMiLCJzb3VyY2VSb290Ijoibmc6Ly9uZ3gtYm9vdHN0cmFwL21pbmktbmdyeC8iLCJzb3VyY2VzIjpbInN0b3JlLmNsYXNzLnRzIl0sIm5hbWVzIjpbXSwibWFwcGluZ3MiOiI7Ozs7Ozs7O0FBR0EsT0FBTyxFQUFFLFVBQVUsRUFBc0IsTUFBTSxNQUFNLENBQUM7QUFDdEQsT0FBTyxFQUFFLG9CQUFvQixFQUFFLEdBQUcsRUFBRSxNQUFNLGdCQUFnQixDQUFDOzs7O0FBRzNEOzs7O0lBQWtDLHFDQUFhO0lBQzdDLG1CQUNVLFdBQTZCLEVBRTdCLFFBQTRCO0lBQ3BDLHNDQUFzQztJQUN0QyxNQUF1QjtRQUx6QixZQU9FLGlCQUFPLFNBSVI7UUFWUyxpQkFBVyxHQUFYLFdBQVcsQ0FBa0I7UUFFN0IsY0FBUSxHQUFSLFFBQVEsQ0FBb0I7UUFNcEMsMkNBQTJDO1FBQzNDLEtBQUksQ0FBQyxNQUFNLEdBQUcsTUFBTSxDQUFDOztJQUN2QixDQUFDOzs7Ozs7SUFFRCwwQkFBTTs7Ozs7SUFBTixVQUFVLFdBQTRCOzs7WUFFOUIsT0FBTyxHQUFrQixJQUFJLENBQUMsTUFBTSxDQUFDLElBQUksQ0FBQyxHQUFHLENBQUMsV0FBVyxDQUFDLENBQUM7UUFFakUsT0FBTyxPQUFPLENBQUMsSUFBSSxDQUFDLG9CQUFvQixFQUFFLENBQUMsQ0FBQztJQUM5QyxDQUFDOzs7Ozs7SUFFRCx3QkFBSTs7Ozs7SUFBSixVQUFRLFFBQXdCOztZQUN4QixLQUFLLEdBQUcsSUFBSSxTQUFTLENBQUksSUFBSSxDQUFDLFdBQVcsRUFBRSxJQUFJLENBQUMsUUFBUSxFQUFFLElBQUksQ0FBQztRQUNyRSwyQ0FBMkM7UUFDM0MsS0FBSyxDQUFDLFFBQVEsR0FBRyxRQUFRLENBQUM7UUFFMUIsT0FBTyxLQUFLLENBQUM7SUFDZixDQUFDOzs7OztJQUVELDRCQUFROzs7O0lBQVIsVUFBUyxNQUFjO1FBQ3JCLElBQUksQ0FBQyxXQUFXLENBQUMsSUFBSSxDQUFDLE1BQU0sQ0FBQyxDQUFDO0lBQ2hDLENBQUM7Ozs7O0lBRUQsd0JBQUk7Ozs7SUFBSixVQUFLLE1BQWM7UUFDakIsSUFBSSxDQUFDLFdBQVcsQ0FBQyxJQUFJLENBQUMsTUFBTSxDQUFDLENBQUM7SUFDaEMsQ0FBQztJQUVELHNDQUFzQzs7Ozs7O0lBQ3RDLHlCQUFLOzs7OztJQUFMLFVBQU0sR0FBUTtRQUNaLElBQUksQ0FBQyxXQUFXLENBQUMsS0FBSyxDQUFDLEdBQUcsQ0FBQyxDQUFDO0lBQzlCLENBQUM7Ozs7SUFFRCw0QkFBUTs7O0lBQVI7UUFDRSxRQUFRO0lBQ1YsQ0FBQztJQUNILGdCQUFDO0FBQUQsQ0FBQyxBQTdDRCxDQUFrQyxVQUFVLEdBNkMzQzs7Ozs7Ozs7OztJQTNDRyxnQ0FBcUM7Ozs7O0lBRXJDLDZCQUFvQyIsInNvdXJjZXNDb250ZW50IjpbIi8qKlxuICogQGNvcHlyaWdodCBuZ3J4XG4gKi9cbmltcG9ydCB7IE9ic2VydmFibGUsIE9ic2VydmVyLCBPcGVyYXRvciB9IGZyb20gJ3J4anMnO1xuaW1wb3J0IHsgZGlzdGluY3RVbnRpbENoYW5nZWQsIG1hcCB9IGZyb20gJ3J4anMvb3BlcmF0b3JzJztcbmltcG9ydCB7IEFjdGlvbiwgQWN0aW9uUmVkdWNlciB9IGZyb20gJy4vaW5kZXgnO1xuXG5leHBvcnQgY2xhc3MgTWluaVN0b3JlPFQ+IGV4dGVuZHMgT2JzZXJ2YWJsZTxUPiBpbXBsZW1lbnRzIE9ic2VydmVyPEFjdGlvbj4ge1xuICBjb25zdHJ1Y3RvcihcbiAgICBwcml2YXRlIF9kaXNwYXRjaGVyOiBPYnNlcnZlcjxBY3Rpb24+LFxuICAgIC8qIHRzbGludDpkaXNhYmxlLW5leHQtbGluZTogbm8tYW55ICovXG4gICAgcHJpdmF0ZSBfcmVkdWNlcjogQWN0aW9uUmVkdWNlcjxhbnk+LFxuICAgIC8qIHRzbGludDpkaXNhYmxlLW5leHQtbGluZTogbm8tYW55ICovXG4gICAgc3RhdGUkOiBPYnNlcnZhYmxlPGFueT5cbiAgKSB7XG4gICAgc3VwZXIoKTtcblxuICAgIC8qIHRzbGludDpkaXNhYmxlLW5leHQtbGluZTogZGVwcmVjYXRpb24gKi9cbiAgICB0aGlzLnNvdXJjZSA9IHN0YXRlJDtcbiAgfVxuXG4gIHNlbGVjdDxSPihwYXRoT3JNYXBGbjogKHN0YXRlOiBUKSA9PiBSKTogT2JzZXJ2YWJsZTxSPiB7XG4gICAgLyogdHNsaW50OmRpc2FibGUtbmV4dC1saW5lOiBkZXByZWNhdGlvbiAqL1xuICAgIGNvbnN0IG1hcHBlZCQ6IE9ic2VydmFibGU8Uj4gPSB0aGlzLnNvdXJjZS5waXBlKG1hcChwYXRoT3JNYXBGbikpO1xuXG4gICAgcmV0dXJuIG1hcHBlZCQucGlwZShkaXN0aW5jdFVudGlsQ2hhbmdlZCgpKTtcbiAgfVxuXG4gIGxpZnQ8Uj4ob3BlcmF0b3I6IE9wZXJhdG9yPFQsIFI+KTogTWluaVN0b3JlPFI+IHtcbiAgICBjb25zdCBzdG9yZSA9IG5ldyBNaW5pU3RvcmU8Uj4odGhpcy5fZGlzcGF0Y2hlciwgdGhpcy5fcmVkdWNlciwgdGhpcyk7XG4gICAgLyogdHNsaW50OmRpc2FibGUtbmV4dC1saW5lOiBkZXByZWNhdGlvbiAqL1xuICAgIHN0b3JlLm9wZXJhdG9yID0gb3BlcmF0b3I7XG5cbiAgICByZXR1cm4gc3RvcmU7XG4gIH1cblxuICBkaXNwYXRjaChhY3Rpb246IEFjdGlvbikge1xuICAgIHRoaXMuX2Rpc3BhdGNoZXIubmV4dChhY3Rpb24pO1xuICB9XG5cbiAgbmV4dChhY3Rpb246IEFjdGlvbikge1xuICAgIHRoaXMuX2Rpc3BhdGNoZXIubmV4dChhY3Rpb24pO1xuICB9XG5cbiAgLyogdHNsaW50OmRpc2FibGUtbmV4dC1saW5lOiBuby1hbnkgKi9cbiAgZXJyb3IoZXJyOiBhbnkpIHtcbiAgICB0aGlzLl9kaXNwYXRjaGVyLmVycm9yKGVycik7XG4gIH1cblxuICBjb21wbGV0ZSgpIHtcbiAgICAvKm5vb3AqL1xuICB9XG59XG4iXX0=