From 6d1f28eb79c6c70b058fcbae5047dbd744764149 Mon Sep 17 00:00:00 2001 From: cel 🌸 Date: Fri, 30 May 2025 13:29:02 +0100 Subject: doc: everything --- src/reader.rs | 7 +++---- 1 file changed, 3 insertions(+), 4 deletions(-) (limited to 'src/reader.rs') diff --git a/src/reader.rs b/src/reader.rs index ea6c804..a403171 100644 --- a/src/reader.rs +++ b/src/reader.rs @@ -8,10 +8,10 @@ use std::{ collections::{HashMap, HashSet, VecDeque}, str, }; -use tokio::io::{AsyncRead, AsyncReadExt}; +use tokio::io::AsyncRead; #[cfg(target_arch = "wasm32")] use tokio::sync::mpsc; -use tracing::{debug, info, trace}; +use tracing::{info, trace}; #[cfg(target_arch = "wasm32")] use wasm_bindgen::{closure::Closure, JsCast}; #[cfg(target_arch = "wasm32")] @@ -29,7 +29,7 @@ use crate::{ static MAX_STANZA_SIZE: usize = 65536; -/// Streaming reader that tracks depth and corresponding available namespaces. +/// Reader that tracks depth and corresponding declared/available namespaces. #[derive(Debug)] pub struct Reader { inner: R, @@ -134,7 +134,6 @@ impl WebSocketOnMessageRead { #[cfg(target_arch = "wasm32")] impl Readable for WebSocketOnMessageRead { async fn read_buf(&mut self, buffer: &mut Buffer) -> Result { - debug!("reading buf"); let msg = self.queue.recv().await; let msg = match msg { Some(msg) => msg, -- cgit