diff options
author | hozan23 <hozan23@proton.me> | 2023-11-21 15:38:45 +0300 |
---|---|---|
committer | hozan23 <hozan23@proton.me> | 2023-11-21 15:42:28 +0300 |
commit | 542897ce2ed7fb8a8627ec8ba8b3490acb29149f (patch) | |
tree | cf4cd602688ebbf6407248fad92eafe048005223 /jsonrpc/src/codec.rs | |
parent | d1ab7d52abc833bb5c65d1e9545e250d589054ee (diff) |
jsonrpc: switch to LF delimiter for reading json, replacing the dummy delimiter
Diffstat (limited to 'jsonrpc/src/codec.rs')
-rw-r--r-- | jsonrpc/src/codec.rs | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/jsonrpc/src/codec.rs b/jsonrpc/src/codec.rs index 41fed06..e198a6e 100644 --- a/jsonrpc/src/codec.rs +++ b/jsonrpc/src/codec.rs @@ -39,12 +39,12 @@ impl Codec { Self { conn, config } } - /// Read all bytes into `buffer` until the `0x0` byte or EOF is + /// Read all bytes into `buffer` until the `0x0A` byte or EOF is /// reached. /// /// If successful, this function will return the total number of bytes read. pub async fn read_until(&self, buffer: &mut Vec<u8>) -> Result<usize> { - let delim = b'\0'; + let delim = b'\n'; let mut read = 0; @@ -57,8 +57,8 @@ impl Codec { match memchr(delim, &tmp_buf) { Some(i) => { - buffer.extend_from_slice(&tmp_buf[..i]); - read += i; + buffer.extend_from_slice(&tmp_buf[..=i]); + read += i + 1; break; } None => { |