saving state

adding tests

saving state

recv tweak

state save

closer to correct flow

fixed missing disconnect check

cleanup

cleanup

adding ALL support

fixes and cleanup

adding more unit tests and fixing bugs

saving state

fix

tweaks

cleanup

benches working

adding disconnect state

making idx handle better

builder pattern

adding better return type

fixing comments

cleanup

fixing issues

fixing bugs

reorg

everything working

removing file

cleaning up benches

file rename

select benchmarks

fixing send logic

fixing select tx

select benchmarks working as expected

Author: zach-schoenberger

Cargo.toml

@@ -21,23 +21,30 @@ crossbeam-queue = "0.3.12"
 crossbeam-utils = "0.8"
 futures = "0.3"
 parking_lot = "0"
-tokio = { version = "1", features = ["time", "rt"], optional=true }
-async-std = {version = "1", optional=true}
-log = { version="0", optional=true}
-smol = {version = "2", optional=true }
+tokio = { version = "1", features = ["time", "rt"], optional = true }
+async-std = { version = "1", optional = true }
+log = { version = "0", optional = true }
+smol = { version = "2", optional = true }
+fastrand = "2.3"
 
 [dev-dependencies]
-tokio = { version = "1", features = ["time", "sync", "rt-multi-thread", "rt", "macros"] }
+tokio = { version = "1", features = [
+  "time",
+  "sync",
+  "rt-multi-thread",
+  "rt",
+  "macros",
+] }
 rand = "0.9"
 rstest = "0"
-captains-log = {version="0.13", features = ["ringfile", "tracing"] }
+captains-log = { version = "0.13", features = ["ringfile", "tracing"] }
 log = "0"
-criterion2 = { version="3.0.2", features = ["async"]}
+criterion2 = { version = "3.0.2", features = ["async"] }
 crossbeam-channel = "0.5"
 
-flume = {version="0.11", features= ["async"] }
-kanal = {version="0.1"}
-async-channel = {version="2.5.0"}
+flume = { version = "0.11", features = ["async"] }
+kanal = { version = "0.1" }
+async-channel = { version = "2.5.0" }
 
 [features]
 default = []
@@ -70,6 +77,10 @@ harness = false
 name = "crossbeam"
 harness = false
 
+[[bench]]
+name = "crossfire_select"
+harness = false
+
 [[bench]]
 name = "flume"
 harness = false
@@ -85,3 +96,6 @@ harness = false
 [[bench]]
 name = "async_channel"
 harness = false
+
+[patch.crates-io]
+crossfire = { path = "." }