val create : read:( 'a -> buf:Bytes.t -> pos:int -> len:int -> int ) -> compression:Capnp.Codecs.compression_t -> 'a -> 'a t
create ~read ~compression descr creates a new context for reading data from the specified descriptor using the specified
The semantics of the
read function shall mimic that of
Unix.read, attempting to read into a substring of the
buf and returning the number of bytes actually read. A read of length 0 indicates end-of-file.
dequeue_message context attempts to remove a complete message from the incoming queue of the read
context. No data will be read from the underlying descriptor.
val bytes_available : 'a t -> int
bytes_available context obtains the number of bytes already read which are currently stored in the read
val read : 'a t -> int
read context attempts to read some data from the underlying descriptor, storing it in the read