Actualizacion maquina principal

[dotfiles/.git] / .config / coc / extensions / node_modules / coc-prettier / node_modules / rxjs / src / internal / util / subscribeToResult.ts

diff --git a/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/src/internal/util/subscribeToResult.ts b/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/src/internal/util/subscribeToResult.ts
new file mode 100644 (file)
index 0000000..31368ce
--- /dev/null
+++ b/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/src/internal/util/subscribeToResult.ts
@@ -0,0 +1,37 @@
+import { Subscription } from '../Subscription';
+import { InnerSubscriber } from '../InnerSubscriber';
+import { OuterSubscriber } from '../OuterSubscriber';
+import { Subscriber } from '../Subscriber';
+import { subscribeTo } from './subscribeTo';
+import { Observable } from '../Observable';
+
+export function subscribeToResult<T, R>(
+  outerSubscriber: OuterSubscriber<T, R>,
+  result: any,
+  outerValue: undefined,
+  outerIndex: undefined,
+  innerSubscriber: InnerSubscriber<T, R>
+): Subscription | undefined;
+
+export function subscribeToResult<T, R>(
+  outerSubscriber: OuterSubscriber<T, R>,
+  result: any,
+  outerValue?: T,
+  outerIndex?: number
+): Subscription | undefined;
+
+export function subscribeToResult<T, R>(
+  outerSubscriber: OuterSubscriber<T, R>,
+  result: any,
+  outerValue?: T,
+  outerIndex?: number,
+  innerSubscriber: Subscriber<R> = new InnerSubscriber(outerSubscriber, outerValue, outerIndex)
+): Subscription | undefined {
+  if (innerSubscriber.closed) {
+    return undefined;
+  }
+  if (result instanceof Observable) {
+    return result.subscribe(innerSubscriber);
+  }
+  return subscribeTo(result)(innerSubscriber) as Subscription;
+}