Minimize deps even more

Cargo.toml

@@ -1,4 +1,5 @@
 [workspace]
+resolver = "2"
 members = [
     "round-based",
     "round-based-tests",

Makefile

@@ -1,10 +1,10 @@
 .PHONY: docs docs-open
 
 docs:
-	RUSTDOCFLAGS="--cfg docsrs" cargo +nightly doc --no-deps
+	RUSTDOCFLAGS="--cfg docsrs" cargo +nightly doc --no-deps --all-features
 
 docs-test:
-	RUSTDOCFLAGS="--cfg docsrs" cargo +nightly test --doc
+	RUSTDOCFLAGS="--cfg docsrs" cargo +nightly test --doc --all-features
 
 docs-open:
-	RUSTDOCFLAGS="--cfg docsrs" cargo +nightly doc --no-deps --open
+	RUSTDOCFLAGS="--cfg docsrs" cargo +nightly doc --no-deps --all-features --open

round-based-derive/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "round-based-derive"
-version = "0.1.0"
+version = "0.2.0"
 edition = "2021"
 
 [lib]

round-based-tests/Cargo.toml

@@ -2,6 +2,7 @@
 name = "round-based-tests"
 version = "0.1.0"
 edition = "2021"
+publish = false
 
 # See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
 

round-based/Cargo.toml

@@ -15,7 +15,7 @@ rustdoc-args = ["--cfg", "docsrs"]
 # See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
 
 [dependencies]
-futures = "0.3"
+futures-util = { version = "0.3", default-features = false }
 phantom-type = "0.3"
 tracing = "0.1"
 thiserror = "1"
@@ -29,6 +29,7 @@ tokio-stream = { version = "0.1", features = ["sync"], optional = true }
 [dev-dependencies]
 trybuild = "1"
 matches = "0.1"
+futures = "0.3"
 
 [features]
 default = []

round-based/src/_docs.rs

@@ -7,14 +7,14 @@ use crate::{Delivery, Incoming, Outgoing};
 pub fn fake_delivery<M>() -> impl Delivery<M> {
     struct FakeDelivery<M>(PhantomType<M>);
     impl<M> Delivery<M> for FakeDelivery<M> {
-        type Send = futures::sink::Drain<Outgoing<M>>;
-        type Receive = futures::stream::Pending<Result<Incoming<M>, Infallible>>;
+        type Send = futures_util::sink::Drain<Outgoing<M>>;
+        type Receive = futures_util::stream::Pending<Result<Incoming<M>, Infallible>>;
 
         type SendError = Infallible;
         type ReceiveError = Infallible;
 
         fn split(self) -> (Self::Receive, Self::Send) {
-            (futures::stream::pending(), futures::sink::drain())
+            (futures_util::stream::pending(), futures_util::sink::drain())
         }
     }
     FakeDelivery(PhantomType::new())

round-based/src/blocking.rs

@@ -59,6 +59,7 @@ impl SpawnBlocking for ExecuteInPlace {
 pub use tokio_backend::SpawnOnTokio;
 
 #[cfg(feature = "runtime-tokio")]
+#[cfg_attr(docsrs, doc(cfg(feature = "dev")))]
 mod tokio_backend {
     use tokio::task::{JoinError, JoinHandle};
 

round-based/src/delivery.rs

@@ -1,6 +1,6 @@
 use std::error::Error;
 
-use futures::{Sink, Stream};
+use futures_util::{Sink, Stream};
 
 /// Networking abstraction
 ///

round-based/src/lib.rs

@@ -27,14 +27,22 @@
 //!   Some protocols may require broadcast channel to be reliable. Simply saying, when party receives a
 //!   broadcast message over reliable channel it should be ensured that everybody else received the same
 //!   message.
+//!
+//! ## Features
+//!
+//! * `dev` enables development tools such as [protocol simulation](simulation)
+//! * `runtime-tokio` tells that [computationally-heavy tasks](blocking) shall be executed using [tokio] runtime
 
 #![cfg_attr(docsrs, feature(doc_cfg))]
 #![deny(missing_docs)]
 #![forbid(unused_crate_dependencies)]
 
-// Fixes false-positive of `unused_crate_dependencies` lint
+/// Fixes false-positive of `unused_crate_dependencies` lint that only occure in the tests
 #[cfg(test)]
-use trybuild as _;
+mod false_positives {
+    use futures as _;
+    use trybuild as _;
+}
 
 pub mod blocking;
 mod delivery;

round-based/src/rounds_router/mod.rs

@@ -52,7 +52,7 @@ use std::collections::HashMap;
 use std::fmt::Debug;
 use std::mem;
 
-use futures::{Stream, StreamExt};
+use futures_util::{Stream, StreamExt};
 use never::Never;
 use phantom_type::PhantomType;
 use thiserror::Error;

round-based/src/simulation.rs

@@ -43,9 +43,10 @@
 use std::pin::Pin;
 use std::sync::atomic::AtomicU64;
 use std::sync::Arc;
+use std::task::ready;
 use std::task::{Context, Poll};
 
-use futures::{ready, Sink, Stream};
+use futures_util::{Sink, Stream};
 use tokio::sync::broadcast;
 use tokio_stream::wrappers::{errors::BroadcastStreamRecvError, BroadcastStream};