From 98a1de91a2dae06323558422c239e5a45fc86e7b Mon Sep 17 00:00:00 2001
From: hozan23 <hozan23@proton.me>
Date: Tue, 28 Nov 2023 22:41:33 +0300
Subject: implement TLS for inbound and outbound connections

---
 core/src/async_utils/timeout.rs | 52 -----------------------------------------
 1 file changed, 52 deletions(-)
 delete mode 100644 core/src/async_utils/timeout.rs

(limited to 'core/src/async_utils/timeout.rs')

diff --git a/core/src/async_utils/timeout.rs b/core/src/async_utils/timeout.rs
deleted file mode 100644
index 7c55e1b..0000000
--- a/core/src/async_utils/timeout.rs
+++ /dev/null
@@ -1,52 +0,0 @@
-use std::{future::Future, time::Duration};
-
-use smol::Timer;
-
-use super::{select, Either};
-use crate::{error::Error, Result};
-
-/// Waits for a future to complete or times out if it exceeds a specified
-/// duration.
-///
-/// # Example
-///
-/// ```
-/// use std::{future, time::Duration};
-///
-/// use karyons_core::async_utils::timeout;
-///
-/// async {
-///     let fut = future::pending::<()>();
-///     assert!(timeout(Duration::from_millis(100), fut).await.is_err());
-/// };
-///
-/// ```
-///
-pub async fn timeout<T, F>(delay: Duration, future1: F) -> Result<T>
-where
-    F: Future<Output = T>,
-{
-    let result = select(Timer::after(delay), future1).await;
-
-    match result {
-        Either::Left(_) => Err(Error::Timeout),
-        Either::Right(res) => Ok(res),
-    }
-}
-
-#[cfg(test)]
-mod tests {
-    use super::*;
-    use std::{future, time::Duration};
-
-    #[test]
-    fn test_timeout() {
-        smol::block_on(async move {
-            let fut = future::pending::<()>();
-            assert!(timeout(Duration::from_millis(10), fut).await.is_err());
-
-            let fut = smol::Timer::after(Duration::from_millis(10));
-            assert!(timeout(Duration::from_millis(50), fut).await.is_ok())
-        });
-    }
-}
-- 
cgit v1.2.3