pub async fn read(&mut self) -> Result<()> {
        loop {
            if self.closed {
                break Ok(());
            }
            match self.read_once().await {
                Err(err) => break Err(err),
                Ok(_) if self.options.once => {
                    break self
                        .close(
                            CloseCode::Normal,
                            "wrangler is closing after receiving first log",
                        )
                        .await
                }
                _ => {}
            };
        }
    }
/// Reads and prints messages from the WebSocket in a loop.
Reads and prints messages from the WebSocket in a loop.
Reads and prints messages from the WebSocket in a loop .
pub async fn read(&mut self) -> Result<()> {
        loop {
            if self.closed {
                break Ok(());
            }
            match self.read_once().await {
                Err(err) => break Err(err),
                Ok(_) if self.options.once => {
                    break self
                        .close(
                            CloseCode::Normal,
                            "wrangler is closing after receiving first log",
                        )
                        .await
                }
                _ => {}
            };
        }
    }
pub async fn read ( & mut self ) -> Result < ( ) > { loop { if self . closed { break Ok ( ( ) ) ; } match self . read_once ( ) . await { Err ( err ) => break Err ( err ) , Ok ( _ ) if self . options . once => { break self . close ( CloseCode :: Normal , " " , ) . await } _ => { } } ; } }
Reads and prints messages from the WebSocket in a loop.
Reads and prints messages from the WebSocket in a loop .
&mut self
&mut self