In workspace:

- Pulled `project-pin-lite` into workspace dependencies. This will later replace `project-pin`.

In `cuprate-p2p-core`:
- Propagated the `send_timeout` field to TcpInBoundStream

In `cuprate-helper`:
- Implemented `WriteTimeout` and `ReadTimeout` wrapper of `AsyncWrite` and `AsyncRead` respectively.
- Implemented `StreamTimeout` wrapper for `AsyncWrite + AsyncRead` types.
- Defined `ExtractDuration` trait for more flexibility on computing the timeout duration.
- Added 6 TCP tests (read/write/ok/err and stream/err)

Author: SyntheticBird45

Cargo.lock

@@ -132,6 +132,7 @@ monero-serai          = { git = "https://github.com/Cuprate/serai.git", rev = "e
 nu-ansi-term          = { version = "0.46", default-features = false }
 paste                 = { version = "1", default-features = false }
 pin-project           = { version = "1", default-features = false }
+pin-project-lite      = { version = "0.2.16", default-features = false }
 randomx-rs            = { git = "https://github.com/Cuprate/randomx-rs.git", rev = "e09955c", default-features = false }
 rand                  = { version = "0.8", default-features = false }
 rand_distr            = { version = "0.4", default-features = false }

Cargo.toml

@@ -24,6 +24,7 @@ time      = ["dep:chrono", "std"]
 thread    = ["std", "dep:target_os_lib"]
 tx        = ["dep:monero-serai"]
 fmt       = ["map", "std"]
+timeout   = ["std", "dep:pin-project-lite", "dep:tokio"]
 
 [dependencies]
 cuprate-constants = { workspace = true, optional = true, features = ["block"] }
@@ -35,6 +36,8 @@ dirs             = { workspace = true, optional = true }
 futures          = { workspace = true, optional = true, features = ["std"] }
 monero-serai     = { workspace = true, optional = true }
 rayon            = { workspace = true, optional = true }
+tokio            = { workspace = true, optional = true, features = ["time"] }
+pin-project-lite = { workspace = true, optional = true }
 
 serde            = { workspace = true, optional = true, features = ["derive"] }
 

helper/Cargo.toml

@@ -14,6 +14,9 @@ pub mod cast;
 #[cfg(feature = "fs")]
 pub mod fs;
 
+#[cfg(feature = "timeout")]
+pub mod timeout;
+
 pub mod network;
 
 #[cfg(feature = "num")]