for_each_measure_in_block

Function for_each_measure_in_block 

Source
pub fn for_each_measure_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(Measure) -> Result<bool, Error>,
Expand description

Iterates over each metric measurement in a block.