aboutsummaryrefslogtreecommitdiffstats
path: root/src/reader.rs
diff options
context:
space:
mode:
Diffstat (limited to 'src/reader.rs')
-rw-r--r--src/reader.rs7
1 files changed, 3 insertions, 4 deletions
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<R> {
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<usize> {
- debug!("reading buf");
let msg = self.queue.recv().await;
let msg = match msg {
Some(msg) => msg,