📁 File Manager Pro
v10.0.3 | PHP: 8.2.31
Server: LiteSpeed
2026-07-03 22:41:09
📂
/ (Root)
/
home
/
orkouolp
/
web
/
testing.orkobd
/
laravel
/
node_modules
/
rxjs
/
dist
/
esm
/
internal
/
operators
📍 /home/orkouolp/web/testing.orkobd/laravel/node_modules/rxjs/dist/esm/internal/operators
🔄 Refresh
✏️
Editing: windowToggle.js
Writable
import { Subject } from '../Subject'; import { Subscription } from '../Subscription'; import { operate } from '../util/lift'; import { innerFrom } from '../observable/innerFrom'; import { createOperatorSubscriber } from './OperatorSubscriber'; import { noop } from '../util/noop'; import { arrRemove } from '../util/arrRemove'; export function windowToggle(openings, closingSelector) { return operate((source, subscriber) => { const windows = []; const handleError = (err) => { while (0 < windows.length) { windows.shift().error(err); } subscriber.error(err); }; innerFrom(openings).subscribe(createOperatorSubscriber(subscriber, (openValue) => { const window = new Subject(); windows.push(window); const closingSubscription = new Subscription(); const closeWindow = () => { arrRemove(windows, window); window.complete(); closingSubscription.unsubscribe(); }; let closingNotifier; try { closingNotifier = innerFrom(closingSelector(openValue)); } catch (err) { handleError(err); return; } subscriber.next(window.asObservable()); closingSubscription.add(closingNotifier.subscribe(createOperatorSubscriber(subscriber, closeWindow, noop, handleError))); }, noop)); source.subscribe(createOperatorSubscriber(subscriber, (value) => { const windowsCopy = windows.slice(); for (const window of windowsCopy) { window.next(value); } }, () => { while (0 < windows.length) { windows.shift().complete(); } subscriber.complete(); }, handleError, () => { while (0 < windows.length) { windows.shift().unsubscribe(); } })); }); } //# sourceMappingURL=windowToggle.js.map
💾 Save Changes
❌ Cancel