tsarevvv/rust-ipfs
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

refactor: use a type alias for pinned+boxed futures

Browse Source 
Signed-off-by: ljedrz <ljedrz@gmail.com>
This commit is contained in:
ljedrz 2020-06-26 14:32:13 +02:00
parent 365a659ef2
commit 304cef3d48
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
bitswap/src/protocol.rs
View File

@ -16,6 +16,8 @@ use std::io;
// https://github.com/ipfs/js-ipfs-bitswap/blob/d8f80408aadab94c962f6b88f343eb9f39fa0fcc/src/decision-engine/index.js#L16
const MAX_BUF_SIZE: usize = 524_288;
type FutureResult<T, E> = Pin<Box<dyn Future<Output = Result<T, E>> + Send>>;
#[derive(Clone, Debug, Default)]
pub struct BitswapConfig {}
@ -35,8 +37,7 @@ where
{
type Output = Message;
type Error = BitswapError;
#[allow(clippy::type_complexity)]
type Future = Pin<Box<dyn Future<Output = Result<Self::Output, Self::Error>> + Send>>;
type Future = FutureResult<Self::Output, Self::Error>;
#[inline]
fn upgrade_inbound(self, mut socket: TSocket, info: Self::Info) -> Self::Future {
@ -66,8 +67,7 @@ where
{
type Output = ();
type Error = io::Error;
#[allow(clippy::type_complexity)]
type Future = Pin<Box<dyn Future<Output = Result<Self::Output, Self::Error>> + Send>>;
type Future = FutureResult<Self::Output, Self::Error>;
#[inline]
fn upgrade_outbound(self, mut socket: TSocket, info: Self::Info) -> Self::Future {