diff --git a/quinn/src/endpoint.rs b/quinn/src/endpoint.rs index 0db2dad4dc..8945f399d9 100644 --- a/quinn/src/endpoint.rs +++ b/quinn/src/endpoint.rs @@ -363,7 +363,7 @@ impl Drop for EndpointDriver { #[derive(Debug)] pub(crate) struct EndpointInner { socket: UdpSocket, - udp_state: Arc, + udp_state: UdpState, inner: proto::Endpoint, outgoing: VecDeque, incoming: VecDeque, @@ -571,7 +571,7 @@ impl EndpointRef { let (dirty_send, dirty) = mpsc::unbounded_channel(); Self(Arc::new(Mutex::new(EndpointInner { socket, - udp_state: Arc::new(UdpState::new()), + udp_state: UdpState::new(), inner, ipv6, outgoing: VecDeque::new(),