@@ -75,7 +75,7 @@ impl Transport {
7575 }
7676
7777 async fn recv(
78− reader: &mut (impl AsyncBufRead + Unpin),
78+ reader: &mut (impl AsyncBufRead + Unpin + Send),
7979 headers: &mut HashMap<String, String>,
8080 ) -> core::result::Result<Message, std::io::Error> {
8181 // read headers
@@ -117,7 +117,7 @@ impl Transport {
117117 }
118118
119119 async fn err(
120− err: &mut (impl AsyncBufRead + Unpin),
120+ err: &mut (impl AsyncBufRead + Unpin + Send),
121121 ) -> core::result::Result<(), std::io::Error> {
122122 let mut line = String::new();
123123 err.read_line(&mut line).await?;