lx/netapp
1
1
Fork 5
Code Issues 2 Pull requests 1 Releases 1 Wiki Activity

add streaming body to requests and responses #3

Merged
lx merged 64 commits from stream-body into main 2022-09-13 10:56:54 +00:00
Conversation 0 Commits 64 Files changed 22 +5
1 changed files with 5 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files
Showing only changes of commit db96af2609 - Show all commits

5
src/message.rs
View file

@ -499,6 +499,11 @@ impl RespEnc {
let msg_len = reader.read_u32().await?; let msg_len = reader.read_u32().await?;
let msg = reader.read_exact(msg_len as usize).await?; let msg = reader.read_exact(msg_len as usize).await?;
// Check whether the response stream still has data or not.
// If no more data is coming, this will defuse the request canceller.
// If we didn't do this, and the client doesn't try to read from the stream,
// the request canceller doesn't know that we read everything and
// sends a cancellation message to the server (which they don't care about).
reader.fill_buffer().await; reader.fill_buffer().await;
Ok(Self { Ok(Self {