diff options
| author | Pinapelz <yukais@pinapelz.com> | 2025-06-29 11:49:28 -0700 |
|---|---|---|
| committer | Pinapelz <yukais@pinapelz.com> | 2025-06-29 11:49:28 -0700 |
| commit | d55b767039605256c736166a942a9138e3eacfd7 (patch) | |
| tree | 947063b634c50d438a794325f13275e134aa5993 /node_modules/rxjs/dist/esm/internal/observable/bindCallbackInternals.js | |
| parent | 864ce67d89c77d8ef9c3361f80d619853abcf91c (diff) | |
remove dev node_modules (oops)
Diffstat (limited to 'node_modules/rxjs/dist/esm/internal/observable/bindCallbackInternals.js')
| -rw-r--r-- | node_modules/rxjs/dist/esm/internal/observable/bindCallbackInternals.js | 62 |
1 files changed, 0 insertions, 62 deletions
diff --git a/node_modules/rxjs/dist/esm/internal/observable/bindCallbackInternals.js b/node_modules/rxjs/dist/esm/internal/observable/bindCallbackInternals.js deleted file mode 100644 index 79015c5..0000000 --- a/node_modules/rxjs/dist/esm/internal/observable/bindCallbackInternals.js +++ /dev/null @@ -1,62 +0,0 @@ -import { isScheduler } from '../util/isScheduler'; -import { Observable } from '../Observable'; -import { subscribeOn } from '../operators/subscribeOn'; -import { mapOneOrManyArgs } from '../util/mapOneOrManyArgs'; -import { observeOn } from '../operators/observeOn'; -import { AsyncSubject } from '../AsyncSubject'; -export function bindCallbackInternals(isNodeStyle, callbackFunc, resultSelector, scheduler) { - if (resultSelector) { - if (isScheduler(resultSelector)) { - scheduler = resultSelector; - } - else { - return function (...args) { - return bindCallbackInternals(isNodeStyle, callbackFunc, scheduler) - .apply(this, args) - .pipe(mapOneOrManyArgs(resultSelector)); - }; - } - } - if (scheduler) { - return function (...args) { - return bindCallbackInternals(isNodeStyle, callbackFunc) - .apply(this, args) - .pipe(subscribeOn(scheduler), observeOn(scheduler)); - }; - } - return function (...args) { - const subject = new AsyncSubject(); - let uninitialized = true; - return new Observable((subscriber) => { - const subs = subject.subscribe(subscriber); - if (uninitialized) { - uninitialized = false; - let isAsync = false; - let isComplete = false; - callbackFunc.apply(this, [ - ...args, - (...results) => { - if (isNodeStyle) { - const err = results.shift(); - if (err != null) { - subject.error(err); - return; - } - } - subject.next(1 < results.length ? results : results[0]); - isComplete = true; - if (isAsync) { - subject.complete(); - } - }, - ]); - if (isComplete) { - subject.complete(); - } - isAsync = true; - } - return subs; - }); - }; -} -//# sourceMappingURL=bindCallbackInternals.js.map
\ No newline at end of file |
