tokio::select! and reference to TokioIo in two branches

[hbagdi]

I have an HTTP connection that gets upgraded and later sent onto a bounded channel (async_channel) if the channel is full (which is most likely).
While the sender.send is blocked (in an async manner), I need to monitor upgraded - if the client sends any data or closes the connection, then the sender.send must be canceled.

Is there a way to do this without wrapping upgraded with Arc and Mutex?

                    match hyper::upgrade::on(req).await {
                        Ok(upgraded) => {
                            debug!("CONNECT upgrade succcessfuly");
                            let svc = "foo"; // TODO
                            let sender = c.grab_sender(svc.to_string()).unwrap();

                            debug!("waiting on send");
                            tokio::select! {
                                send = sender.send(Conn{stream: upgraded}) => {
                                    match send {
                                        Ok(_)=> debug!("connect send succcessfuly"),
                                        Err(err)=>error!("failed to send CONNECT seocket: {}",err),
                                    }
                                },
                                // TODO: if the 'upgraded' is closed by client, cancel the send
                            }
                        }