pub trait SequenceFileSource:
Send
+ Sync
+ 'static {
type Cursor: Default + Send;
// Provided methods
fn next(
&self,
_current_task: &CurrentTask,
_cursor: Self::Cursor,
_sink: &mut DynamicFileBuf,
) -> Result<Option<Self::Cursor>, Errno> { ... }
fn next_locked(
&self,
_locked: &mut Locked<FileOpsCore>,
current_task: &CurrentTask,
cursor: Self::Cursor,
sink: &mut DynamicFileBuf,
) -> Result<Option<Self::Cursor>, Errno> { ... }
}