Skip to content

Commit

Permalink
fix lint
Browse files Browse the repository at this point in the history
  • Loading branch information
rucciva committed Oct 15, 2024
1 parent d5d41b8 commit 4bdf5e6
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions src/transport/http2.rs
Original file line number Diff line number Diff line change
Expand Up @@ -149,15 +149,15 @@ impl Service<Request<Incoming>> for Svc {

fn call(&self, req: Request<Incoming>) -> Self::Future {
let req_sender = self.req_sender.clone();
let addr = self.addr.clone();
let addr = self.addr;

let future = async move {
let (res_sender, mut res_receiver) = mpsc::channel::<OutgoingSimplex>(1);
if let Err(_) = req_sender
if let Err(err) = req_sender
.send(Ok((addr, req.into_body(), res_sender)))
.await
{
return Err(anyhow!("Channel closed"));
return Err(anyhow!(err.to_string()));
}

match res_receiver.recv().await {
Expand Down

0 comments on commit 4bdf5e6

Please sign in to comment.