few lines

src/websoket_connection.rs

@@ -3,7 +3,7 @@ use crate::{
     response::Response,
 };
 
-use tokio::io::{self, AsyncWriteExt};
+use tokio::io::{self, AsyncReadExt, AsyncWriteExt};
 use tokio::net::TcpStream;
 
 use base64::prelude::*;
@@ -50,7 +50,10 @@ impl WebsocketConnection {
         todo!()
     }
 
-    pub async fn read_next_message(&self) {
+    pub async fn read_next_message(&mut self) -> io::Result<DataBlock> {
+        let mut first_line: [u8; 2] = [0; 2];
+        self.stream.read_exact(&mut first_line).await?;
+
         todo!()
     }