beetswap 0.5.0

Implementation of bitswap protocol for libp2p
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23

use std::future::poll_fn;
use std::task::{Context, Poll};

use cid::Cid;
use multihash_codetable::{Code, MultihashDigest};

pub const RAW_CODEC: u64 = 0x55;

pub fn cid_of_data(data: &[u8]) -> Cid {
    let hash = Code::Sha2_256.digest(data);
    Cid::new_v1(RAW_CODEC, hash)
}

pub(crate) async fn poll_fn_once<T, F>(mut f: F) -> Option<T>
where
    F: FnMut(&mut Context<'_>) -> Poll<T>,
{
    poll_fn(|cx| match f(cx) {
        Poll::Ready(val) => Poll::Ready(Some(val)),
        Poll::Pending => Poll::Ready(None),
    })
    .await
}