📁 File Manager Pro
v10.0.3 | PHP: 8.2.31
Server: LiteSpeed
2026-07-02 13:00:37
📂
/ (Root)
/
home
/
orkouolp
/
web
/
testing.orkobd
/
laravel
/
node_modules
/
rxjs
/
dist
/
cjs
/
internal
/
operators
📍 /home/orkouolp/web/testing.orkobd/laravel/node_modules/rxjs/dist/cjs/internal/operators
🔄 Refresh
✏️
Editing: debounceTime.js
Writable
"use strict"; Object.defineProperty(exports, "__esModule", { value: true }); exports.debounceTime = void 0; var async_1 = require("../scheduler/async"); var lift_1 = require("../util/lift"); var OperatorSubscriber_1 = require("./OperatorSubscriber"); function debounceTime(dueTime, scheduler) { if (scheduler === void 0) { scheduler = async_1.asyncScheduler; } return lift_1.operate(function (source, subscriber) { var activeTask = null; var lastValue = null; var lastTime = null; var emit = function () { if (activeTask) { activeTask.unsubscribe(); activeTask = null; var value = lastValue; lastValue = null; subscriber.next(value); } }; function emitWhenIdle() { var targetTime = lastTime + dueTime; var now = scheduler.now(); if (now < targetTime) { activeTask = this.schedule(undefined, targetTime - now); subscriber.add(activeTask); return; } emit(); } source.subscribe(OperatorSubscriber_1.createOperatorSubscriber(subscriber, function (value) { lastValue = value; lastTime = scheduler.now(); if (!activeTask) { activeTask = scheduler.schedule(emitWhenIdle, dueTime); subscriber.add(activeTask); } }, function () { emit(); subscriber.complete(); }, undefined, function () { lastValue = activeTask = null; })); }); } exports.debounceTime = debounceTime; //# sourceMappingURL=debounceTime.js.map
💾 Save Changes
❌ Cancel