Function dataflow::source::s3::read_object_chunked

async fn read_object_chunked<R>(
    source_id: &str, 
    reader: R, 
    tx: &Sender<Result<InternalMessage, S3Error>>
) -> Result<DownloadMetricUpdate, DownloadError> where
    R: Unpin + AsyncRead,