package core_kernel

  1. Overview
  2. Docs
Industrial strength alternative to OCaml's standard library

Install 

dune-project
 Dependency

github.com Changelog MIT License Edit opam file Versions (10)

Authors

  1. J
    Jane Street Group, LLC

Maintainers

  1. J
    Jane Street developers

Sources

v0.17.0.tar.gz
sha256=fd2b8c6715794df7a810a62b226f53720f211cd344b4afc9fab0498796d6b466

doc/core_kernel.unpack_buffer/Unpack_buffer/index.html

Module Unpack_bufferSource

A buffer for incremental decoding of an input stream.

An Unpack_buffer.t is a buffer to which one can feed strings, and then unpack from the buffer to produce a queue of values.

Sourcemodule Unpack_one : sig ... end

If unpack_one : ('a, 'state) unpack, then unpack_one ~state ~buf ~pos ~len must unpack at most one value of type 'a from buf starting at pos, and not using more than len characters. unpack_one must return one the following:

Sourcetype 'a t
Sourceval sexp_of_t : ('a -> Sexplib0.Sexp.t) -> 'a t -> Sexplib0.Sexp.t
include Core.Invariant.S1 with type 'a t := 'a t
Sourceval invariant : ('a -> unit) -> 'a t -> unit
Sourceval create : 'a Unpack_one.t -> 'a t
Sourceval create_bin_prot : 'a Core.Bin_prot.Type_class.reader -> 'a t

create_bin_prot reader returns an unpack buffer that unpacks the "size-prefixed" bin_prot encoding, in which a value is encoded by first writing the length of the bin_prot data as a 64-bit int, and then writing the bin_prot data itself.

Sourceval is_empty : _ t -> bool Core.Or_error.t

is_empty returns true if all the data fed into t has been unpacked into values; false if t has unconsumed bytes or partially unpacked data. is_empty returns an error if t has encountered an unpacking error.

Sourceval feed : ?pos:int -> ?len:int -> _ t -> Core.Bigstring.t -> unit Core.Or_error.t

feed t buf ?pos ?len adds the specified substring of buf to t's buffer. It returns an error if t has encountered an unpacking error.

Sourceval feed_string : ?pos:int -> ?len:int -> _ t -> string -> unit Core.Or_error.t
Sourceval feed_bytes : ?pos:int -> ?len:int -> _ t -> Core.Bytes.t -> unit Core.Or_error.t
Sourceval unpack_into : 'a t -> 'a Core.Queue.t -> unit Core.Or_error.t

unpack_into t q unpacks all the values that it can from t and enqueues them in q. If there is an unpacking error, unpack_into returns an error, and subsequent feed and unpack operations on t will return that same error -- i.e. no more data can be fed to or unpacked from t.

Sourceval unpack_iter : 'a t -> f:('a -> unit) -> unit Core.Or_error.t

unpack_iter t ~f unpacks all the values that it can from t, calling f on each value as it's unpacked. If there is an unpacking error (including if f raises), unpack_iter returns an error, and subsequent feed and unpack operations on t will return that same error -- i.e., no more data can be fed to or unpacked from t.

Behavior is unspecified if f operates on t.

Sourceval debug : bool ref

debug controls whether invariants are checked at each call. Setting this to true can make things very slow.