Function dataflow::source::s3::download_objects_task [−][src]
async fn download_objects_task(
source_id: String,
rx: Receiver<Result<KeyInfo, S3Error>>,
tx: Sender<Result<InternalMessage, S3Error>>,
shutdown_rx: Receiver<DataflowStatus>,
aws_config: AwsConfig,
activator: SyncActivator,
compression: Compression,
metrics: SourceBaseMetrics
)