From 0dcada47a3415be02b2476e3364556bb6fae4c48 Mon Sep 17 00:00:00 2001
From: Benjamin Sparks <b.sparks@alugha.com>
Date: Mon, 30 Dec 2024 17:13:21 +0100
Subject: [PATCH] async-nats: test push consumer config, label segments

---
 async-nats/tests/jetstream_tests.rs | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/async-nats/tests/jetstream_tests.rs b/async-nats/tests/jetstream_tests.rs
index d827e39eb..4b0dd9be2 100755
--- 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(),
                     ),