Up

Module Buffer

Handles allocating Iobuf.t and making sure there's enough space in it.

Signature

val get_header_chunk : unit -> (Core.Std.read, _) Core.Std.Iobuf.t
val ensure_free : int -> unit

All of these will push the current chunk into the list of previous chunks first; a new chunk will then be allocated on the next write.

val is_empty : unit -> bool

Is the main (short message) buffer empty?

module Unsafe_internals : sig .. end
To aid producing test cases for Reader.