Fix absinthe-graphql#12

Lean5 · Aug 14, 2018 · 5faae55 · 5faae55
1 parent 86e5d47
commit 5faae55
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/packages/socket-apollo-link/src/createAbsintheSocketLink.js b/packages/socket-apollo-link/src/createAbsintheSocketLink.js
@@ -59,7 +59,7 @@ const notifierToObservable = (absintheSocket, onError, onStart) => notifier => {
   };
 
   return new Observable(subscriber => {
-    observer.onAbort = subscriber.error;
+    observer.onAbort = subscriber.error.bind(subscriber);
     observer.onResult = onResult(notifier, subscriber);
     observe(absintheSocket, notifier, observer);
 

diff --git a/packages/socket/src/toObservable.js b/packages/socket/src/toObservable.js
@@ -37,12 +37,12 @@ const toObservable = <Result>(
   notifier: Notifier<Result>,
   {onError, onStart, unsubscribe}: $Shape<Options<Result>> = {}
 ) =>
-  new Observable(observer => {
+  new Observable(subscriber => {
     observe(absintheSocket, notifier, {
       onError,
       onStart,
-      onAbort: observer.error,
-      onResult: onResult(notifier, observer)
+      onAbort: subscriber.error.bind(subscriber),
+      onResult: onResult(notifier, subscriber)
     });
 
     return unsubscribe;