fix async-buffer builds

This commit is contained in:
Boog900 2024-05-30 01:27:27 +01:00
parent a53279a8c6
commit a4ca123589
No known key found for this signature in database
GPG key ID: 42AB1287CB0041C2
3 changed files with 12 additions and 1 deletions

10
Cargo.lock generated
View file

@ -98,6 +98,16 @@ dependencies = [
"windows-sys 0.52.0",
]
[[package]]
name = "async-buffer"
version = "0.1.0"
dependencies = [
"futures",
"pin-project",
"thiserror",
"tokio",
]
[[package]]
name = "async-lock"
version = "3.3.0"

View file

@ -13,6 +13,7 @@ members = [
"p2p/cuprate-p2p",
"p2p/dandelion",
"p2p/monero-p2p",
"p2p/async-buffer",
"p2p/address-book",
"storage/cuprate-blockchain",
"storage/cuprate-txpool",

View file

@ -48,7 +48,7 @@ pub fn new_buffer<T>(max_item_weight: usize) -> (BufferAppender<T>, BufferStream
queue: tx,
sink_waker: sink_waker.clone(),
capacity: capacity_atomic.clone(),
max_item_weight: capacity,
max_item_weight,
},
BufferStream {
queue: rx,