fast_pull/base/
event.rs

1use crate::ProgressEntry;
2
3pub type WorkerId = usize;
4
5#[derive(Debug)]
6pub enum Event<ReadError, WriteError> {
7    Reading(WorkerId),
8    ReadError(WorkerId, ReadError),
9    ReadProgress(WorkerId, ProgressEntry),
10    WriteError(WorkerId, WriteError),
11    WriteProgress(WorkerId, ProgressEntry),
12    FlushError(WriteError),
13    Finished(WorkerId),
14    Abort(WorkerId),
15}