Packages

ewe

3.0.5
4.0.1 4.0.0 3.0.8 3.0.7 3.0.6 3.0.5 3.0.4 3.0.3 3.0.2 3.0.1 3.0.0 2.1.3 2.1.2 2.1.1 2.1.0 2.0.3 2.0.2 2.0.1 2.0.0 1.0.1 1.0.0 1.0.0-rc2 1.0.0-rc1 0.10.0 0.9.0 0.8.1 0.8.0 0.7.0 0.6.0 0.5.0 0.4.0 0.3.0 0.2.0 0.1.0 0.0.2 0.0.1

🐑 a fluffy Gleam web server

Security advisory: This version has known vulnerabilities. View advisories
HexDocs

Current section

Files

Jump to
Readme
36 Versions
9 Dependencies
Dependants
3 Advisories
Files
Activity
ewe src ewe internal http1 buffer.gleam
Raw

src/ewe/internal/http1/buffer.gleam 

import gleam/bit_array

import gleam/int



/// Buffer holding data read from a socket, along with how many more bytes are

/// expected (pending) before the current read operation is complete.

///

pub type Buffer {

  Buffer(data: BitArray, pending: Int)

}



/// Appends data to the buffer and decrements pending bytes accordingly.

///

pub fn append(buffer: Buffer, data: BitArray) -> Buffer {

  let pending = int.max(0, buffer.pending - bit_array.byte_size(data))

  Buffer(<<buffer.data:bits, data:bits>>, pending)

}



/// Splits the buffer data at the given byte boundary. Returns the first part

/// and the rest.

///

pub fn split(buffer: Buffer, bytes: Int) -> #(BitArray, BitArray) {

  case buffer.data {

    <<partition:bytes-size(bytes), rest:bits>> -> #(partition, rest)

    _ -> #(buffer.data, <<>>)

  }

}