update tests

Author: fafhrd91

.github/workflows/windows.yml

@@ -32,12 +32,6 @@ jobs:
         with:
           command: generate-lockfile
 
-      - name: Cache vcpkg
-        uses: actions/cache@v1
-        with:
-          path: C:\vcpkg\installed\x64-windows\
-          key: x86_64-pc-windows-msvc-openssl-${{ hashFiles('**/Cargo.lock') }}
-
       - name: Cache cargo registry
         uses: actions/cache@v1
         with:

ntex/src/util/keepalive.rs

@@ -13,6 +13,9 @@ use crate::{Service, ServiceFactory};
 
 use super::time::{LowResTime, LowResTimeService};
 
+/// KeepAlive service factory
+///
+/// Controls min time between requests.
 pub struct KeepAlive<R, E, F> {
     f: F,
     ka: Duration,
@@ -24,11 +27,15 @@ impl<R, E, F> KeepAlive<R, E, F>
 where
     F: Fn() -> E + Clone,
 {
-    pub fn new(ka: Duration, time: LowResTime, f: F) -> Self {
+    /// Construct KeepAlive service factory.
+    ///
+    /// ka - keep-alive timeout
+    /// err - error factory function
+    pub fn new(ka: Duration, time: LowResTime, err: F) -> Self {
         KeepAlive {
-            f,
             ka,
             time,
+            f: err,
             _t: PhantomData,
         }
     }
@@ -134,3 +141,36 @@ where
         ok(req)
     }
 }
+
+#[cfg(test)]
+mod tests {
+    use futures::future::lazy;
+
+    use super::*;
+    use crate::rt::time::delay_for;
+    use crate::service::{Service, ServiceFactory};
+
+    #[derive(Debug, PartialEq)]
+    struct TestErr;
+
+    #[ntex_rt::test]
+    async fn test_ka() {
+        let factory = KeepAlive::new(
+            Duration::from_millis(100),
+            LowResTime::with(Duration::from_millis(10)),
+            || TestErr,
+        );
+        let _ = factory.clone();
+
+        let service = factory.new_service(()).await.unwrap();
+
+        assert_eq!(service.call(1usize).await, Ok(1usize));
+        assert!(lazy(|cx| service.poll_ready(cx)).await.is_ready());
+
+        delay_for(Duration::from_millis(500)).await;
+        assert_eq!(
+            lazy(|cx| service.poll_ready(cx)).await,
+            Poll::Ready(Err(TestErr))
+        );
+    }
+}