Merge branch 'bugfix/interceptors-stream' of https://github.com/AlexDaSoul/nest into AlexDaSoul-bugfix/interceptors-stream

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

Original file line number	Diff line number	Diff line change
`@@ -30,7 +30,8 @@ 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`	`+ // return result$.toPromise(); # Promise breaking Observable stream`
`34`	`35`	`}`
`35`	`36`
`36`	`37`	`public createContext(`