summaryrefslogtreecommitdiff
path: root/ext/http
diff options
context:
space:
mode:
authorMatt Mastracci <matthew@mastracci.com>2023-07-13 15:16:24 -0600
committerGitHub <noreply@github.com>2023-07-13 15:16:24 -0600
commit8465bd0037acbaac0c7dfab6a8c6dbf47539934e (patch)
treec2ba7e1ba75a45ba552f40f7a09407674a890916 /ext/http
parentc5ddb5f205dcd6b273b0b451f01f79b68621b2e4 (diff)
chore: update to Rust 1.71 (#19822)
Diffstat (limited to 'ext/http')
-rw-r--r--ext/http/websocket_upgrade.rs9
1 files changed, 3 insertions, 6 deletions
diff --git a/ext/http/websocket_upgrade.rs b/ext/http/websocket_upgrade.rs
index 70ad78526..f57f9e56b 100644
--- a/ext/http/websocket_upgrade.rs
+++ b/ext/http/websocket_upgrade.rs
@@ -131,12 +131,9 @@ impl<T: Default> WebSocketUpgrade<T> {
HEADER_SEARCHER.get_or_init(|| TwoWaySearcher::new(b"\r\n\r\n"));
let header_searcher2 =
HEADER_SEARCHER2.get_or_init(|| TwoWaySearcher::new(b"\n\n"));
- if let Some(..) = header_searcher.search_in(&self.buf) {
- let (index, response) = parse_response(&self.buf)?;
- let mut buf = std::mem::take(&mut self.buf);
- self.state = Complete;
- Ok(Some((response, buf.split_off(index).freeze())))
- } else if let Some(..) = header_searcher2.search_in(&self.buf) {
+ if header_searcher.search_in(&self.buf).is_some()
+ || header_searcher2.search_in(&self.buf).is_some()
+ {
let (index, response) = parse_response(&self.buf)?;
let mut buf = std::mem::take(&mut self.buf);
self.state = Complete;