diff options
| -rw-r--r-- | mullvad-masque-proxy/src/client/mod.rs | 25 |
1 files changed, 6 insertions, 19 deletions
diff --git a/mullvad-masque-proxy/src/client/mod.rs b/mullvad-masque-proxy/src/client/mod.rs index 21c806c6cd..4fd7ee5729 100644 --- a/mullvad-masque-proxy/src/client/mod.rs +++ b/mullvad-masque-proxy/src/client/mod.rs @@ -246,25 +246,12 @@ impl Client { // log::trace!("Received datagram with an unexpected stream ID"); continue; } - let mut payload = response.into_payload(); - let context = VarInt::decode(&mut payload); - match context { - Ok(crate::HTTP_MASQUE_DATAGRAM_CONTEXT_ID) => { - self.client_socket - .send_to(payload.as_ref(), return_addr) - .await - .map_err(Error::ClientWrite)?; - } - Ok(crate::HTTP_MASQUE_FRAGMENTED_DATAGRAM_CONTEXT_ID) => { - if let Ok(Some(payload)) = self.fragments.handle_incoming_packet(payload) { - self.client_socket - .send_to(payload.chunk(), return_addr) - .await - .map_err(Error::ClientWrite)?; - } - }, - _ => (), - + let payload = response.into_payload(); + if let Ok(Some(payload)) = self.fragments.handle_incoming_packet(payload) { + self.client_socket + .send_to(payload.chunk(), return_addr) + .await + .map_err(Error::ClientWrite)?; } } Ok(None) => { |