Actualizacion maquina principal

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

diff --git a/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/src/internal/util/subscribeToObservable.ts b/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/src/internal/util/subscribeToObservable.ts
new file mode 100644 (file)
index 0000000..b53c566
--- /dev/null
+++ b/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/src/internal/util/subscribeToObservable.ts
@@ -0,0 +1,17 @@
+import { Subscriber } from '../Subscriber';
+import { observable as Symbol_observable } from '../symbol/observable';
+
+/**
+ * Subscribes to an object that implements Symbol.observable with the given
+ * Subscriber.
+ * @param obj An object that implements Symbol.observable
+ */
+export const subscribeToObservable = <T>(obj: any) => (subscriber: Subscriber<T>) => {
+  const obs = obj[Symbol_observable]();
+  if (typeof obs.subscribe !== 'function') {
+    // Should be caught by observable subscribe function error handling.
+    throw new TypeError('Provided object does not correctly implement Symbol.observable');
+  } else {
+    return obs.subscribe(subscriber);
+  }
+};