Cuprate/cuprate
Cuprate/cuprate
1
0
Fork 0
mirror of https://github.com/Cuprate/cuprate.git synced 2024-11-16 15:58:17 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

more docs
Some checks failed
Deny / audit (push) Has been cancelled
Details

Browse source
This commit is contained in:
Boog900 2024-11-05 00:49:02 +00:00
parent 252bbea5b4
commit 692d4b2550
No known key found for this signature in database
GPG key ID: 42AB1287CB0041C2
2 changed files with 9 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

14
binaries/cuprated/src/txpool/dandelion/stem_service.rs
View file

@ -1,12 +1,11 @@
use bytes::Bytes;
use futures::future::BoxFuture;
use futures::{FutureExt, Stream};
use std::future::Future;
use std::task::ready;
use std::{
future::Future,
pin::Pin,
task::{Context, Poll},
task::{ready, Context, Poll},
};
use bytes::Bytes;
use futures::{future::BoxFuture, FutureExt, Stream};
use tower::Service;
use cuprate_dandelion_tower::{traits::StemRequest, OutboundPeer};
@ -73,8 +72,11 @@ impl Stream for OutboundPeerStream {
}
}
/// The state of the [`OutboundPeerStream`].
enum OutboundPeerStreamState {
/// Standby state.
Standby,
/// Awaiting a response from the peer-set.
AwaitingPeer(BoxFuture<'static, Result<PeerSetResponse<ClearNet>, tower::BoxError>>),
}

3
p2p/p2p/src/block_downloader/request_chain.rs
View file

@ -1,8 +1,7 @@
use std::mem;
use tokio::{task::JoinSet, time::timeout};
use tower::util::BoxCloneService;
use tower::{Service, ServiceExt};
use tower::{util::BoxCloneService, Service, ServiceExt};
use tracing::{instrument, Instrument, Span};
use cuprate_p2p_core::{