From 6555fb80fdd8f6a5d201efadec3189d1244830a0 Mon Sep 17 00:00:00 2001 From: Nevena Bojovic Date: Tue, 1 Mar 2022 22:05:25 +0100 Subject: Izbrisala bin, obj i node-modules. --- .../rxjs/_esm2015/internal/innerSubscribe.js | 78 ---------------------- 1 file changed, 78 deletions(-) delete mode 100644 sandbox/testAppNevena/Front/node_modules/rxjs/_esm2015/internal/innerSubscribe.js (limited to 'sandbox/testAppNevena/Front/node_modules/rxjs/_esm2015/internal/innerSubscribe.js') diff --git a/sandbox/testAppNevena/Front/node_modules/rxjs/_esm2015/internal/innerSubscribe.js b/sandbox/testAppNevena/Front/node_modules/rxjs/_esm2015/internal/innerSubscribe.js deleted file mode 100644 index dafe988b..00000000 --- a/sandbox/testAppNevena/Front/node_modules/rxjs/_esm2015/internal/innerSubscribe.js +++ /dev/null @@ -1,78 +0,0 @@ -import { Subscriber } from './Subscriber'; -import { Observable } from './Observable'; -import { subscribeTo } from './util/subscribeTo'; -export class SimpleInnerSubscriber extends Subscriber { - constructor(parent) { - super(); - this.parent = parent; - } - _next(value) { - this.parent.notifyNext(value); - } - _error(error) { - this.parent.notifyError(error); - this.unsubscribe(); - } - _complete() { - this.parent.notifyComplete(); - this.unsubscribe(); - } -} -export class ComplexInnerSubscriber extends Subscriber { - constructor(parent, outerValue, outerIndex) { - super(); - this.parent = parent; - this.outerValue = outerValue; - this.outerIndex = outerIndex; - } - _next(value) { - this.parent.notifyNext(this.outerValue, value, this.outerIndex, this); - } - _error(error) { - this.parent.notifyError(error); - this.unsubscribe(); - } - _complete() { - this.parent.notifyComplete(this); - this.unsubscribe(); - } -} -export class SimpleOuterSubscriber extends Subscriber { - notifyNext(innerValue) { - this.destination.next(innerValue); - } - notifyError(err) { - this.destination.error(err); - } - notifyComplete() { - this.destination.complete(); - } -} -export class ComplexOuterSubscriber extends Subscriber { - notifyNext(_outerValue, innerValue, _outerIndex, _innerSub) { - this.destination.next(innerValue); - } - notifyError(error) { - this.destination.error(error); - } - notifyComplete(_innerSub) { - this.destination.complete(); - } -} -export function innerSubscribe(result, innerSubscriber) { - if (innerSubscriber.closed) { - return undefined; - } - if (result instanceof Observable) { - return result.subscribe(innerSubscriber); - } - let subscription; - try { - subscription = subscribeTo(result)(innerSubscriber); - } - catch (error) { - innerSubscriber.error(error); - } - return subscription; -} -//# sourceMappingURL=innerSubscribe.js.map \ No newline at end of file -- cgit v1.2.3