maurice/snix
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

feat(tvix/nix-compat): add BytesReader

Browse source 
This adds AsyncRead counterpart for read_bytes.

Change-Id: I751da9944984c7a523abee305f8f8a050e705f04
Reviewed-on: https://cl.tvl.fyi/c/depot/+/11385
Tested-by: BuildkiteCI
Reviewed-by: raitobezarius <tvl@lahfa.xyz>
Reviewed-by: Brian Olsen <me@griff.name>
Autosubmit: flokli <flokli@flokli.de>
This commit is contained in:
Florian Klink 2024-04-08 17:59:05 +03:00 • committed by flokli
parent 82cf89ee6e
commit eeca2d92e2
6 changed files with 481 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

4
tvix/nix-compat/src/wire/bytes_writer.rs
View file

@ -6,7 +6,7 @@ use tokio::io::AsyncWrite;
use super::bytes::EMPTY_BYTES;
/// The length of the size field, in bytes is always 8.
const LEN_SIZE: usize = 8;
pub(crate) const LEN_SIZE: usize = 8;
pin_project! {
/// Writes a "bytes wire packet" to the underlying writer.
@ -52,6 +52,8 @@ pin_project! {
/// move to the beginning of the next one:
/// - Size(LEN_SIZE) must be expressed as Payload(0)
/// - Payload(self.payload_len) must be expressed as Padding(0)
/// There's one exception - Size(LEN_SIZE) in the reader represents a failure
/// state we enter in case the allowed size doesn't match the allowed range.
///
/// Padding(padding_len) means we're at the end of the bytes wire packet.
#[derive(Clone, Debug, PartialEq, Eq)]