Function consume_log_stream

Source

pub(crate) async fn consume_log_stream<S: Sink>(
    sink: S,
    log_reader: MockRangeLogReader,
    sink_writer_param: SinkWriterParam,
) -> Result<(), String>

consume_log_stream

Function consume_log_stream Copy item path

Function consume_log_stream