From e4fa1e69e7ebfb627c7198fd1a9881e9327ec4d4 Mon Sep 17 00:00:00 2001 From: Pinapelz Date: Sat, 28 Jun 2025 17:26:46 -0700 Subject: initial commit: scaffolding --- .../rxjs/dist/esm5/internal/operators/single.js | 30 ++++++++++++++++++++++ 1 file changed, 30 insertions(+) create mode 100644 node_modules/rxjs/dist/esm5/internal/operators/single.js (limited to 'node_modules/rxjs/dist/esm5/internal/operators/single.js') diff --git a/node_modules/rxjs/dist/esm5/internal/operators/single.js b/node_modules/rxjs/dist/esm5/internal/operators/single.js new file mode 100644 index 0000000..ed324d0 --- /dev/null +++ b/node_modules/rxjs/dist/esm5/internal/operators/single.js @@ -0,0 +1,30 @@ +import { EmptyError } from '../util/EmptyError'; +import { SequenceError } from '../util/SequenceError'; +import { NotFoundError } from '../util/NotFoundError'; +import { operate } from '../util/lift'; +import { createOperatorSubscriber } from './OperatorSubscriber'; +export function single(predicate) { + return operate(function (source, subscriber) { + var hasValue = false; + var singleValue; + var seenValue = false; + var index = 0; + source.subscribe(createOperatorSubscriber(subscriber, function (value) { + seenValue = true; + if (!predicate || predicate(value, index++, source)) { + hasValue && subscriber.error(new SequenceError('Too many matching values')); + hasValue = true; + singleValue = value; + } + }, function () { + if (hasValue) { + subscriber.next(singleValue); + subscriber.complete(); + } + else { + subscriber.error(seenValue ? new NotFoundError('No matching values') : new EmptyError()); + } + })); + }); +} +//# sourceMappingURL=single.js.map \ No newline at end of file -- cgit v1.2.3