use std::pin::Pin;
use bytes::Bytes;
use futures::stream::BoxStream;
use libipld::Cid;
use tokio::io::AsyncRead;
use crate::{IpldStore, Layout, StoreResult};
#[derive(Clone, Debug, PartialEq)]
pub struct BalancedDagLayout {
degree: usize,
}
impl Layout for BalancedDagLayout {
async fn organize<'a>(
&self,
_stream: BoxStream<'a, StoreResult<Bytes>>,
_store: impl IpldStore + Send + 'a,
) -> StoreResult<BoxStream<'a, StoreResult<Cid>>> {
todo!() }
async fn retrieve<'a>(
&self,
_cid: &Cid,
_store: impl IpldStore + Send + 'a,
) -> StoreResult<Pin<Box<dyn AsyncRead + Send + Sync + 'a>>> {
todo!() }
}