fix(process): The stream filter needs to be created per request.

Torsten Link · Torsten Link · commit 6c7bb8678dbc · 2016-01-26T00:20:59.000+01:00
diff --git a/lib/interceptor.js b/lib/interceptor.js
@@ -12,8 +12,6 @@ class ChunkProcessorInterceptor extends Interceptor {
 
 	constructor(endpoint, config) {
 		super(endpoint, config);
-
-		this.streamFilter = parserFactory(config, true);
 	}
 
 	static get type() {
@@ -26,8 +24,9 @@ class ChunkProcessorInterceptor extends Interceptor {
 
 	receive(request, oldRequest) {
 		if (request.payload) {
+			const streamFilter = parserFactory(this.config, true);
 			const stream = request.payload;
-			request.payload = stream.pipe(this.streamFilter);
+			request.payload = stream.pipe(streamFilter);
 		}
 		return this.connected.receive(request, oldRequest);
 	}

Original file line number	Diff line number	Diff line change
`@@ -12,8 +12,6 @@ class ChunkProcessorInterceptor extends Interceptor {`
`12`	`12`
`13`	`13`	`constructor(endpoint, config) {`
`14`	`14`	`super(endpoint, config);`
`15`		`-`
`16`		`- this.streamFilter = parserFactory(config, true);`
`17`	`15`	`}`
`18`	`16`
`19`	`17`	`static get type() {`
`@@ -26,8 +24,9 @@ class ChunkProcessorInterceptor extends Interceptor {`
`26`	`24`
`27`	`25`	`receive(request, oldRequest) {`
`28`	`26`	`if (request.payload) {`
	`27`	`+ const streamFilter = parserFactory(this.config, true);`
`29`	`28`	`const stream = request.payload;`
`30`		`- request.payload = stream.pipe(this.streamFilter);`
	`29`	`+ request.payload = stream.pipe(streamFilter);`
`31`	`30`	`}`
`32`	`31`	`return this.connected.receive(request, oldRequest);`
`33`	`32`	`}`