Merge branch 'AlexDaSoul-bugfix/interceptors-stream'

kamilmysliwiec · kamilmysliwiec · commit 7edf59841a6d · 2019-02-05T13:44:42.000+01:00
diff --git a/packages/core/interceptors/interceptors-consumer.ts b/packages/core/interceptors/interceptors-consumer.ts
@@ -30,7 +30,7 @@ export class InterceptorsConsumer {
       async (stream$, interceptor) => interceptor.intercept(context, await stream$),
       Promise.resolve(start$),
     );
-    return result$.toPromise();
+    return result$;
   }
 
   public createContext(

Original file line number	Diff line number	Diff line change
`@@ -30,7 +30,7 @@ export class InterceptorsConsumer {`
`30`	`30`	`async (stream$, interceptor) => interceptor.intercept(context, await stream$),`
`31`	`31`	`Promise.resolve(start$),`
`32`	`32`	`);`
`33`		`- return result$.toPromise();`
	`33`	`+ return result$;`
`34`	`34`	`}`
`35`	`35`
`36`	`36`	`public createContext(`