Include async-std to cov action (#160)

* async std for cov

.github/workflows/cov.yml

@@ -9,10 +9,8 @@ jobs:
       CARGO_TERM_COLOR: always
     steps:
       - uses: actions/checkout@v3
-
       - name: Install Rust
-        run: rustup toolchain install stable --component llvm-tools-preview
-
+        run: rustup update nightly
       - name: Install cargo-llvm-cov
         uses: taiki-e/install-action@cargo-llvm-cov
 
@@ -24,14 +22,20 @@ jobs:
       - name: Cache Dependencies
         uses: Swatinem/rust-cache@v1.0.1
 
-      - name: Code coverage
-        run: cargo llvm-cov --no-report --all --no-default-features --features="tokio,cookie,url,compress,openssl,rustls"
+      - name: Clean coverage results
+        run: cargo llvm-cov clean --workspace
 
       - name: Code coverage (glommio)
         run: cargo llvm-cov --no-report --all --no-default-features --features="glommio,cookie,url,compress,openssl,rustls"
 
+      - name: Code coverage (async-std)
+        run: cargo llvm-cov --no-report --all --no-default-features --features="async-std,cookie,url,compress,openssl,rustls"
+
+      - name: Code coverage
+        run: cargo +nightly llvm-cov --no-report --all --doctests --no-default-features --features="tokio,cookie,url,compress,openssl,rustls"
+
       - name: Generate coverage report
-        run: cargo llvm-cov report --lcov --output-path lcov.info --ignore-filename-regex="ntex-tokio|ntex-glommio|ntex-async-std"
+        run: cargo +nightly llvm-cov report --lcov --output-path lcov.info --ignore-filename-regex="ntex-tokio|ntex-glommio|ntex-async-std"
 
       - name: Upload coverage to Codecov
         uses: codecov/codecov-action@v3

ntex-io/src/testing.rs

@@ -648,6 +648,7 @@ pub(super) fn flush_io(
 #[allow(clippy::redundant_clone)]
 mod tests {
     use super::*;
+    use ntex_util::future::lazy;
 
     #[ntex::test]
     async fn basic() {
@@ -656,6 +657,17 @@ mod tests {
         assert_eq!(client.clone().tp, Type::ClientClone);
         assert_eq!(server.tp, Type::Server);
         assert_eq!(server.clone().tp, Type::ServerClone);
+        assert!(format!("{:?}", server).contains("IoTest"));
+        assert!(format!("{:?}", AtomicWaker::default()).contains("AtomicWaker"));
+
+        server.read_pending();
+        let mut buf = BytesVec::new();
+        let res = lazy(|cx| client.poll_read_buf(cx, &mut buf)).await;
+        assert!(res.is_pending());
+
+        server.read_pending();
+        let res = lazy(|cx| server.poll_write_buf(cx, b"123")).await;
+        assert!(res.is_pending());
 
         assert!(!server.is_client_dropped());
         drop(client);
@@ -665,5 +677,8 @@ mod tests {
         assert!(!server2.is_server_dropped());
         drop(server);
         assert!(server2.is_server_dropped());
+
+        let res = lazy(|cx| server2.poll_write_buf(cx, b"123")).await;
+        assert!(res.is_pending());
     }
 }