summaryrefslogtreecommitdiff
path: root/test_util/src/lib.rs
diff options
context:
space:
mode:
Diffstat (limited to 'test_util/src/lib.rs')
-rw-r--r--test_util/src/lib.rs12
1 files changed, 7 insertions, 5 deletions
diff --git a/test_util/src/lib.rs b/test_util/src/lib.rs
index 9b84db7f3..136576890 100644
--- a/test_util/src/lib.rs
+++ b/test_util/src/lib.rs
@@ -382,7 +382,7 @@ async fn ping_websocket_handler(
let mut ws = fastwebsockets::FragmentCollector::new(ws);
for i in 0..9 {
- ws.write_frame(Frame::new(true, OpCode::Ping, None, vec![]))
+ ws.write_frame(Frame::new(true, OpCode::Ping, None, vec![].into()))
.await
.unwrap();
@@ -390,9 +390,11 @@ async fn ping_websocket_handler(
assert_eq!(frame.opcode, OpCode::Pong);
assert!(frame.payload.is_empty());
- ws.write_frame(Frame::text(format!("hello {}", i).as_bytes().to_vec()))
- .await
- .unwrap();
+ ws.write_frame(Frame::text(
+ format!("hello {}", i).as_bytes().to_vec().into(),
+ ))
+ .await
+ .unwrap();
let frame = ws.read_frame().await.unwrap();
assert_eq!(frame.opcode, OpCode::Text);
@@ -419,7 +421,7 @@ async fn close_websocket_handler(
) -> Result<(), anyhow::Error> {
let mut ws = fastwebsockets::FragmentCollector::new(ws);
- ws.write_frame(fastwebsockets::Frame::close_raw(vec![]))
+ ws.write_frame(fastwebsockets::Frame::close_raw(vec![].into()))
.await
.unwrap();