Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
BufQueue<B: Buf>
is aVecDeque<B>
which implementsBuf
andcaches the remaining size.
This utility can be used to implement outgoing network buffer.
Imagine this use case:
New messages can be queues by simply appending to this
BufQueue
,and the queue can be flushed by invoking
bytes_vectored
on thequeue object.
And both enqueue and flush operations are zero-copy.
remaining
cache is needed to optimizebytes
operation, whichmight be expensive if the queue is long.
I'm not 100% sure this is how
Bytes
is meant to be used, but thisBufQueue
type seems to be the most natural way.