Add slow_tests feature

Signed-off-by: Tomasz Pietrek <tomasz@nats.io>

.github/workflows/test.yml

@@ -79,7 +79,7 @@ jobs:
         run: |
           rustup update
           nats-server --jetstream --port=4222 &
-          cargo test --features=${{ matrix.features }} -- --nocapture
+          cargo test --features=${{ matrix.features }} --features slow_tests -- --nocapture
 
   check_format:
     name: check (format)

async-nats/Cargo.toml

@@ -54,6 +54,7 @@ async-nats = {path = ".", features = ["experimental"]}
 service = []
 experimental = ["service"]
 "server-2.10" = []
+slow_tests = []
 
 
 [[bench]]

async-nats/tests/jetstream_tests.rs

@@ -44,7 +44,6 @@ mod jetstream {
     use futures::stream::{StreamExt, TryStreamExt};
     use time::OffsetDateTime;
     use tokio_retry::Retry;
-    use tracing::debug;
 
     #[tokio::test]
     async fn query_account_requests() {
@@ -1898,8 +1897,10 @@ mod jetstream {
         println!("time elapsed {:?}", now.elapsed());
     }
 
+    #[cfg(feature = "slow_tests")]
     #[tokio::test]
     async fn pull_consumer_long_idle() {
+        use tracing::debug;
         let server = nats_server::run_server("tests/configs/jetstream.conf");
         let client = ConnectOptions::new()
             .event_callback(|err| async move { println!("error: {err:?}") })
@@ -1951,6 +1952,7 @@ mod jetstream {
         messages.next().await.unwrap().unwrap();
     }
 
+    #[cfg(feature = "slow_tests")]
     #[tokio::test]
     async fn pull_consumer_stream_with_heartbeat() {
         use tracing::debug;