summaryrefslogtreecommitdiff
path: root/ext/websocket/stream.rs
diff options
context:
space:
mode:
authorBartek IwaƄczuk <biwanczuk@gmail.com>2023-12-26 11:20:49 +0100
committerGitHub <noreply@github.com>2023-12-26 11:20:49 +0100
commit753777b4affb6020739b4f74932a278f6f8afcce (patch)
tree639b75de5868c2db48069fbc23c4acc98490bcab /ext/websocket/stream.rs
parentd1f4d81dcf6a03463d82a89d058337acecca0588 (diff)
refactor: migrate ext/websocket to hyper 1.1 (#21699)
Diffstat (limited to 'ext/websocket/stream.rs')
-rw-r--r--ext/websocket/stream.rs9
1 files changed, 5 insertions, 4 deletions
diff --git a/ext/websocket/stream.rs b/ext/websocket/stream.rs
index 7e36c8147..7e0201ae4 100644
--- a/ext/websocket/stream.rs
+++ b/ext/websocket/stream.rs
@@ -2,9 +2,10 @@
use bytes::Buf;
use bytes::Bytes;
use deno_net::raw::NetworkStream;
-use h2::RecvStream;
-use h2::SendStream;
-use hyper::upgrade::Upgraded;
+use h2_04::RecvStream;
+use h2_04::SendStream;
+use hyper1::upgrade::Upgraded;
+use hyper_util::rt::TokioIo;
use std::io::ErrorKind;
use std::pin::Pin;
use std::task::ready;
@@ -15,7 +16,7 @@ use tokio::io::ReadBuf;
// TODO(bartlomieju): remove this
pub(crate) enum WsStreamKind {
- Upgraded(Upgraded),
+ Upgraded(TokioIo<Upgraded>),
Network(NetworkStream),
H2(SendStream<Bytes>, RecvStream),
}