diff options
Diffstat (limited to 'node_modules/rxjs/dist/cjs/internal/operators/publishReplay.js')
| -rw-r--r-- | node_modules/rxjs/dist/cjs/internal/operators/publishReplay.js | 15 |
1 files changed, 15 insertions, 0 deletions
diff --git a/node_modules/rxjs/dist/cjs/internal/operators/publishReplay.js b/node_modules/rxjs/dist/cjs/internal/operators/publishReplay.js new file mode 100644 index 0000000..15061cb --- /dev/null +++ b/node_modules/rxjs/dist/cjs/internal/operators/publishReplay.js @@ -0,0 +1,15 @@ +"use strict"; +Object.defineProperty(exports, "__esModule", { value: true }); +exports.publishReplay = void 0; +var ReplaySubject_1 = require("../ReplaySubject"); +var multicast_1 = require("./multicast"); +var isFunction_1 = require("../util/isFunction"); +function publishReplay(bufferSize, windowTime, selectorOrScheduler, timestampProvider) { + if (selectorOrScheduler && !isFunction_1.isFunction(selectorOrScheduler)) { + timestampProvider = selectorOrScheduler; + } + var selector = isFunction_1.isFunction(selectorOrScheduler) ? selectorOrScheduler : undefined; + return function (source) { return multicast_1.multicast(new ReplaySubject_1.ReplaySubject(bufferSize, windowTime, timestampProvider), selector)(source); }; +} +exports.publishReplay = publishReplay; +//# sourceMappingURL=publishReplay.js.map
\ No newline at end of file |
