Add test for push consumer config with sample freq

bengsparks · web-flow · commit 95e5f2e8b04c · 2025-01-02T12:26:11.000+01:00
Co-authored-by: Benjamin Sparks &lt;b.sparks@alugha.com&gt;
diff --git a/async-nats/tests/jetstream_tests.rs b/async-nats/tests/jetstream_tests.rs
@@ -2586,6 +2586,7 @@ mod jetstream {
             .await
             .unwrap();
 
+        // Pull Consumer
         {
             let consumer = stream
                 .create_consumer(consumer::pull::Config {
@@ -2602,10 +2603,12 @@ mod jetstream {
             assert_eq!(100, consumer.cached_info().config.sample_frequency);
         }
 
+        // Push Consumer
         {
             let consumer = stream
-                .create_consumer(consumer::pull::Config {
+                .create_consumer(consumer::push::Config {
                     name: Some("SampledPushConsumer".into()),
+                    deliver_subject: "DeliverSubject".into(),
                     description: Some(
                         "See below to check that Ack Sampling has been set to 100%!".to_string(),
                     ),

Original file line number	Diff line number	Diff line change
`@@ -2586,6 +2586,7 @@ mod jetstream {`
`2586`	`2586`	`.await`
`2587`	`2587`	`.unwrap();`
`2588`	`2588`
	`2589`	`+ // Pull Consumer`
`2589`	`2590`	`{`
`2590`	`2591`	`let consumer = stream`
`2591`	`2592`	`.create_consumer(consumer::pull::Config {`
`@@ -2602,10 +2603,12 @@ mod jetstream {`
`2602`	`2603`	`assert_eq!(100, consumer.cached_info().config.sample_frequency);`
`2603`	`2604`	`}`
`2604`	`2605`
	`2606`	`+ // Push Consumer`
`2605`	`2607`	`{`
`2606`	`2608`	`let consumer = stream`
`2607`		`- .create_consumer(consumer::pull::Config {`
	`2609`	`+ .create_consumer(consumer::push::Config {`
`2608`	`2610`	`name: Some("SampledPushConsumer".into()),`
	`2611`	`+ deliver_subject: "DeliverSubject".into(),`
`2609`	`2612`	`description: Some(`
`2610`	`2613`	`"See below to check that Ack Sampling has been set to 100%!".to_string(),`
`2611`	`2614`	`),`