aboutsummaryrefslogtreecommitdiff
path: root/client/src/lib.rs
diff options
context:
space:
mode:
Diffstat (limited to 'client/src/lib.rs')
-rw-r--r--client/src/lib.rs5
1 files changed, 3 insertions, 2 deletions
diff --git a/client/src/lib.rs b/client/src/lib.rs
index 200c869..92545a9 100644
--- a/client/src/lib.rs
+++ b/client/src/lib.rs
@@ -12,6 +12,7 @@ use reqwest::{
use serde_json::json;
use std::time::Duration;
use stream::StreamSpec;
+use tokio::io::AsyncWriteExt;
pub use jellycommon::*;
@@ -93,7 +94,7 @@ impl Session {
&self,
id: &str,
role: &str,
- mut writer: impl std::io::Write,
+ mut writer: impl tokio::io::AsyncWrite + std::marker::Unpin,
) -> Result<()> {
debug!("downloading asset {role:?} for {id:?}");
let mut r = self
@@ -102,7 +103,7 @@ impl Session {
.send()
.await?;
while let Some(chunk) = r.chunk().await? {
- writer.write_all(&chunk)?;
+ writer.write_all(&chunk).await?;
}
Ok(())
}