Struct TermSource 

pub(crate) struct TermSource {
    filestore: Arc<FileStore>,
    hub: Arc<FeedHub>,
    block_id: String,
}

Where a terminal feed reads the terminal’s output from: its term file.

Fields

filestore: Arc<FileStore>

hub: Arc<FeedHub>

block_id: String

Implementations

impl TermSource

pub(crate) fn of(state: &AppState, block_id: &str) -> Self

async fn read_from(&self, from: Option<u64>) -> Option<(u64, u64, Vec<u8>)>

The file’s size and its bytes from from (None: from terminal::SNAPSHOT_TAIL_BYTES before the end), on the blocking pool.

async fn snapshot(&self) -> Option<TermSnapshot>

The tail, from a line start.

async fn resume(&self, from: u64) -> Option<(u64, Vec<u8>)>

The bytes from from on, for a reconnect: None when from is past the end (the file was truncated) or more than a snapshot holds was written since (a snapshot then). One event never carries more than a snapshot would: a device’s event-stream parser bounds a line’s length.