aboutsummaryrefslogtreecommitdiffstats
path: root/node_modules/rxjs/dist/esm/internal/operators/windowTime.js
diff options
context:
space:
mode:
Diffstat (limited to 'node_modules/rxjs/dist/esm/internal/operators/windowTime.js')
-rw-r--r--node_modules/rxjs/dist/esm/internal/operators/windowTime.js63
1 files changed, 63 insertions, 0 deletions
diff --git a/node_modules/rxjs/dist/esm/internal/operators/windowTime.js b/node_modules/rxjs/dist/esm/internal/operators/windowTime.js
new file mode 100644
index 0000000..eb37ebb
--- /dev/null
+++ b/node_modules/rxjs/dist/esm/internal/operators/windowTime.js
@@ -0,0 +1,63 @@
+import { Subject } from '../Subject';
+import { asyncScheduler } from '../scheduler/async';
+import { Subscription } from '../Subscription';
+import { operate } from '../util/lift';
+import { createOperatorSubscriber } from './OperatorSubscriber';
+import { arrRemove } from '../util/arrRemove';
+import { popScheduler } from '../util/args';
+import { executeSchedule } from '../util/executeSchedule';
+export function windowTime(windowTimeSpan, ...otherArgs) {
+ var _a, _b;
+ const scheduler = (_a = popScheduler(otherArgs)) !== null && _a !== void 0 ? _a : asyncScheduler;
+ const windowCreationInterval = (_b = otherArgs[0]) !== null && _b !== void 0 ? _b : null;
+ const maxWindowSize = otherArgs[1] || Infinity;
+ return operate((source, subscriber) => {
+ let windowRecords = [];
+ let restartOnClose = false;
+ const closeWindow = (record) => {
+ const { window, subs } = record;
+ window.complete();
+ subs.unsubscribe();
+ arrRemove(windowRecords, record);
+ restartOnClose && startWindow();
+ };
+ const startWindow = () => {
+ if (windowRecords) {
+ const subs = new Subscription();
+ subscriber.add(subs);
+ const window = new Subject();
+ const record = {
+ window,
+ subs,
+ seen: 0,
+ };
+ windowRecords.push(record);
+ subscriber.next(window.asObservable());
+ executeSchedule(subs, scheduler, () => closeWindow(record), windowTimeSpan);
+ }
+ };
+ if (windowCreationInterval !== null && windowCreationInterval >= 0) {
+ executeSchedule(subscriber, scheduler, startWindow, windowCreationInterval, true);
+ }
+ else {
+ restartOnClose = true;
+ }
+ startWindow();
+ const loop = (cb) => windowRecords.slice().forEach(cb);
+ const terminate = (cb) => {
+ loop(({ window }) => cb(window));
+ cb(subscriber);
+ subscriber.unsubscribe();
+ };
+ source.subscribe(createOperatorSubscriber(subscriber, (value) => {
+ loop((record) => {
+ record.window.next(value);
+ maxWindowSize <= ++record.seen && closeWindow(record);
+ });
+ }, () => terminate((consumer) => consumer.complete()), (err) => terminate((consumer) => consumer.error(err))));
+ return () => {
+ windowRecords = null;
+ };
+ });
+}
+//# sourceMappingURL=windowTime.js.map \ No newline at end of file
send patches to the email below
yukais@pinapelz.com
include the subject [PATCH repo_name]
pinapelz.com
homepage