Skip to content

Commit

Permalink
fix typo
Browse files Browse the repository at this point in the history
  • Loading branch information
waahm7 committed Dec 5, 2024
1 parent 227180a commit f0e7d2b
Show file tree
Hide file tree
Showing 3 changed files with 4 additions and 4 deletions.
2 changes: 1 addition & 1 deletion aws-s3-transfer-manager/examples/cp.rs
Original file line number Diff line number Diff line change
Expand Up @@ -173,7 +173,7 @@ async fn do_download(args: Args) -> Result<(), BoxError> {
// TM will handle it's own thread pool for filesystem work
let mut handle = tm.download().bucket(bucket).key(key).initiate()?;

write_body(handle.ouput_mut(), dest)
write_body(handle.output_mut(), dest)
.instrument(tracing::debug_span!("write-output"))
.await?;

Expand Down
2 changes: 1 addition & 1 deletion aws-s3-transfer-manager/src/operation/download/handle.rs
Original file line number Diff line number Diff line change
Expand Up @@ -59,7 +59,7 @@ impl DownloadHandle {
}

/// Mutable reference to the output
pub fn ouput_mut(&mut self) -> &mut DownloadOutput {
pub fn output_mut(&mut self) -> &mut DownloadOutput {
&mut self.output
}

Expand Down
4 changes: 2 additions & 2 deletions aws-s3-transfer-manager/tests/download_test.rs
Original file line number Diff line number Diff line change
Expand Up @@ -46,7 +46,7 @@ fn dummy_expected_request() -> http_02x::Request<SdkBody> {

/// drain/consume the output and return the body.
async fn drain(handle: &mut DownloadHandle) -> Result<Bytes, Error> {
let output = handle.ouput_mut();
let output = handle.output_mut();
let mut data = BytesMut::new();
let mut error: Option<Error> = None;
while let Some(chunk) = output.next().await {
Expand Down Expand Up @@ -173,7 +173,7 @@ async fn test_output_not_consumed() {
.initiate()
.unwrap();

let _ = handle.ouput_mut().next().await;
let _ = handle.output_mut().next().await;
}

#[tokio::test(flavor = "multi_thread", worker_threads = 2)]
Expand Down

0 comments on commit f0e7d2b

Please sign in to comment.