aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorLibravatar cel 🌸 <cel@bunny.garden>2025-04-30 15:56:24 +0100
committerLibravatar cel 🌸 <cel@bunny.garden>2025-04-30 15:56:24 +0100
commit94afe363ea88a6fd036d1681542d650e7cd3c2e7 (patch)
treea91bbf689c782b10463252f34538209ba09bd277
parent9aa337bd703426f737c5d4f94fe84c4a646b7836 (diff)
downloadpeanuts-94afe363ea88a6fd036d1681542d650e7cd3c2e7.tar.gz
peanuts-94afe363ea88a6fd036d1681542d650e7cd3c2e7.tar.bz2
peanuts-94afe363ea88a6fd036d1681542d650e7cd3c2e7.zip
feat: ReadableStringHEADmain
-rw-r--r--src/reader.rs10
1 files changed, 9 insertions, 1 deletions
diff --git a/src/reader.rs b/src/reader.rs
index 751ee1d..a46c66b 100644
--- a/src/reader.rs
+++ b/src/reader.rs
@@ -1,4 +1,3 @@
-#[cfg(target_arch = "wasm32")]
use std::io::Write;
use circular::Buffer;
@@ -149,6 +148,15 @@ impl Readable for WebSocketOnMessageRead {
}
}
+pub struct ReadableString(pub String);
+
+impl Readable for ReadableString {
+ async fn read_buf(&mut self, buffer: &mut Buffer) -> Result<usize> {
+ let string = self.0.split_off(0);
+ Ok(buffer.write(string.as_bytes())?)
+ }
+}
+
pub trait Readable {
fn read_buf(&mut self, buffer: &mut Buffer)
-> impl std::future::Future<Output = Result<usize>>;