Fix tests behind feature flags

nats-io · Jul 24, 2023 · 928e924 · 928e924
1 parent 6f81bc2
commit 928e924
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/async-nats/examples/pub.rs b/async-nats/examples/pub.rs
@@ -11,9 +11,9 @@
 // See the License for the specific language governing permissions and
 // limitations under the License.
 
+use async_nats::{connect, Error, Subject};
 use bytes::Bytes;
 use std::time::Instant;
-use async_nats::{Subject, Error, connect};
 
 #[tokio::main]
 async fn main() -> Result<(), Error> {

diff --git a/async-nats/tests/jetstream_tests.rs b/async-nats/tests/jetstream_tests.rs
@@ -3019,7 +3019,7 @@ mod jetstream {
 
         while let Some((i, message)) = stream.next().await {
             let message = message.unwrap();
-            assert_eq!(from_utf8(&message.payload).unwrap(), i.into());
+            assert_eq!(from_utf8(&message.payload).unwrap(), i.to_string());
         }
     }
 
@@ -3215,7 +3215,7 @@ mod jetstream {
         let mut messages = consumer.messages().await.unwrap().take(1000);
         let message = messages.next().await.unwrap().unwrap();
 
-        assert_eq!(message.subject, "fromtest.transformed.test");
+        assert_eq!(message.subject.as_str(), "fromtest.transformed.test");
     }
 
     #[tokio::test]