diff options
author | 2025-04-30 15:56:24 +0100 | |
---|---|---|
committer | 2025-04-30 15:56:24 +0100 | |
commit | 94afe363ea88a6fd036d1681542d650e7cd3c2e7 (patch) | |
tree | a91bbf689c782b10463252f34538209ba09bd277 | |
parent | 9aa337bd703426f737c5d4f94fe84c4a646b7836 (diff) | |
download | peanuts-94afe363ea88a6fd036d1681542d650e7cd3c2e7.tar.gz peanuts-94afe363ea88a6fd036d1681542d650e7cd3c2e7.tar.bz2 peanuts-94afe363ea88a6fd036d1681542d650e7cd3c2e7.zip |
-rw-r--r-- | src/reader.rs | 10 |
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>>; |