@@ -75,7 +75,7 @@ impl Transport {
77 async fn recv(
77 async fn recv(
78− reader: &mut (impl AsyncBufRead + Unpin),
78+ reader: &mut (impl AsyncBufRead + Unpin + Send),
79 headers: &mut HashMap<String, String>,
79 headers: &mut HashMap<String, String>,
80 ) -> core::result::Result<Message, std::io::Error> {
80 ) -> core::result::Result<Message, std::io::Error> {
81 // read headers
81 // read headers
@@ -117,7 +117,7 @@ impl Transport {
119 async fn err(
119 async fn err(
120− err: &mut (impl AsyncBufRead + Unpin),
120+ err: &mut (impl AsyncBufRead + Unpin + Send),
121 ) -> core::result::Result<(), std::io::Error> {
121 ) -> core::result::Result<(), std::io::Error> {
122 let mut line = String::new();
122 let mut line = String::new();
123 err.read_line(&mut line).await?;
123 err.read_line(&mut line).await?;