Fix tests behind feature flags

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> {

async-nats/tests/jetstream_tests.rs

@@ -41,6 +41,8 @@ mod jetstream {
     use async_nats::jetstream::stream::{self, DiscardPolicy, StorageType};
     use async_nats::jetstream::AckKind;
     use async_nats::ConnectOptions;
+    #[cfg(feature = "slow_tests")]
+    use bytes::Bytes;
     use futures::stream::{StreamExt, TryStreamExt};
     use time::OffsetDateTime;
     use tokio_retry::Retry;
@@ -2990,7 +2992,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());
         }
     }
 
@@ -3186,7 +3188,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]