Function consume_log_stream

pub(crate) async fn consume_log_stream<S: Sink>(
    sink: S,
    log_reader: MockRangeLogReader,
    sink_writer_param: SinkWriterParam,
) -> Result<(), String>
where
    <S as Sink>::Coordinator: Send + 'static,