for_each_log_entry_in_block

Function for_each_log_entry_in_block 

Source
pub fn for_each_log_entry_in_block<Predicate>(
    blob_storage: Arc<BlobStorage>,
    convert_ticks: &ConvertTicks,
    process: Arc<ProcessMetadata>,
    stream: &StreamMetadata,
    block: &BlockMetadata,
    fun: Predicate,
) -> impl Future<Output = Result<bool, Error>>
where Predicate: FnMut(LogEntry) -> Result<bool, Error>,
Expand description

Iterates over all log entries in a block.