fix: Fix consumer filter erasing (#119)

gleip · web-flow · commit 17c782364dc7 · 2024-08-19T19:37:36.000+03:00
diff --git a/src/StreamManager.ts b/src/StreamManager.ts
@@ -155,7 +155,7 @@ export class StreamManager extends Root {
     }
 
     if (isConsumerOptsBuilder(options)) {
-      await this.jsm.consumers.add(streamName, options.config);
+      await this.jsm.consumers.add(streamName, { ...options.config, filter_subject: subject });
     }
 
     return isPullConsumer

Original file line number	Diff line number	Diff line change
`@@ -155,7 +155,7 @@ export class StreamManager extends Root {`
`155`	`155`	`}`
`156`	`156`
`157`	`157`	`if (isConsumerOptsBuilder(options)) {`
`158`		`- await this.jsm.consumers.add(streamName, options.config);`
	`158`	`+ await this.jsm.consumers.add(streamName, { ...options.config, filter_subject: subject });`
`159`	`159`	`}`
`160`	`160`
`161`	`161`	`return isPullConsumer`