scatter_net/scatter_net/put/inner/
writable.rs

1use ps_datachunk::OwnedDataChunk;
2use ps_hkey::Hkey;
3use ps_promise::Promise;
4
5use crate::{PeerGroupAsyncStoreError, ScatterNet};
6
7#[derive(Debug)]
8pub enum PutInnerWritable {
9    Initial {
10        chunk: OwnedDataChunk,
11        net: ScatterNet,
12    },
13    Processing {
14        hkey: Option<Hkey>,
15        pending: Vec<Promise<Hkey, PeerGroupAsyncStoreError>>,
16    },
17    Done {
18        hkey: Hkey,
19    },
20}