aboutsummaryrefslogtreecommitdiff
path: root/jsonrpc/src/codec.rs
diff options
context:
space:
mode:
authorhozan23 <hozan23@proton.me>2023-11-21 15:38:45 +0300
committerhozan23 <hozan23@proton.me>2023-11-21 15:42:28 +0300
commit542897ce2ed7fb8a8627ec8ba8b3490acb29149f (patch)
treecf4cd602688ebbf6407248fad92eafe048005223 /jsonrpc/src/codec.rs
parentd1ab7d52abc833bb5c65d1e9545e250d589054ee (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.rs8
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 => {