Bin_io (core_kernel.core_kernel.iobuf.Iobuf.Bin

Read and advance

val consume : 
  'a Core.Bin_prot.Type_class.reader ->
  ([> Core.read ],
    Iobuf__.Iobuf_type_intf.Definitions.no_seek,
    Core.Modes.At_locality.global)
    t @ local ->
  'a

val unsafe_consume : 
  'a Core.Bin_prot.Type_class.reader ->
  ([> Core.read ],
    Iobuf__.Iobuf_type_intf.Definitions.no_seek,
    Core.Modes.At_locality.global)
    t @ local ->
  'a

Read without advancing

val peek : 
  'a Core.Bin_prot.Read.reader ->
  (_, _, Core.Modes.At_locality.global) t @ local ->
  (pos:int ->
  'a) @ local

val unsafe_peek : 
  'a Core.Bin_prot.Read.reader ->
  (_, _, Core.Modes.At_locality.global) t @ local ->
  (pos:int ->
  'a) @ local

Write and advance

val fill : 
  'a Core.Bin_prot.Type_class.writer ->
  (Core.read_write,
    Iobuf__.Iobuf_type_intf.Definitions.no_seek,
    Core.Modes.At_locality.global)
    t @ local ->
  ('a ->
  unit) @ local

val fill__local : 
  'a Core.Bin_prot.Size.sizer__local ->
  'a Core.Bin_prot.Write.writer__local ->
  (Core.read_write,
    Iobuf__.Iobuf_type_intf.Definitions.no_seek,
    Core.Modes.At_locality.global)
    t @ local ->
  ('a @ local ->
  unit) @ local

val unsafe_fill : 
  'a Core.Bin_prot.Type_class.writer ->
  (Core.read_write,
    Iobuf__.Iobuf_type_intf.Definitions.no_seek,
    Core.Modes.At_locality.global)
    t @ local ->
  ('a ->
  unit) @ local

val unsafe_fill__local : 
  'a Core.Bin_prot.Size.sizer__local ->
  'a Core.Bin_prot.Write.writer__local ->
  (Core.read_write,
    Iobuf__.Iobuf_type_intf.Definitions.no_seek,
    Core.Modes.At_locality.global)
    t @ local ->
  ('a @ local ->
  unit) @ local

Write without advancing

val poke : 
  'a Core.Bin_prot.Type_class.writer ->
  (Core.read_write, _, Core.Modes.At_locality.global) t @ local ->
  (pos:int ->
  ('a ->
  unit) @ local) @ local

val poke_size : 
  'a Core.Bin_prot.Type_class.writer ->
  (Core.read_write, _, Core.Modes.At_locality.global) t @ local ->
  (pos:int ->
  ('a ->
  int) @ local) @ local

val unsafe_poke : 
  'a Core.Bin_prot.Type_class.writer ->
  (Core.read_write, _, Core.Modes.At_locality.global) t @ local ->
  (pos:int ->
  ('a ->
  unit) @ local) @ local

val unsafe_poke_size : 
  'a Core.Bin_prot.Type_class.writer ->
  (Core.read_write, _, Core.Modes.At_locality.global) t @ local ->
  (pos:int ->
  ('a ->
  int) @ local) @ local

val unsafe_poke_with_known_size : 
  'a Core.Bin_prot.Write.writer ->
  (Core.read_write, _, Core.Modes.At_locality.global) t @ local ->
  (pos:int ->
  (size:int ->
  ('a ->
  unit) @ local) @ local) @ local

Include length of bin_prot payload as a header

val header_bytes : int

val consume_with_header : 
  ([> Core.read ],
    Iobuf__.Iobuf_type_intf.Definitions.no_seek,
    Core.Modes.At_locality.global)
    t @ local ->
  ('a Core.Bin_prot.Type_class.reader ->
  'a Core.Or_error.t) @ local

val fill_with_header : 
  ([> Core.write ],
    Iobuf__.Iobuf_type_intf.Definitions.no_seek,
    Core.Modes.At_locality.global)
    t @ local ->
  ('a Core.Bin_prot.Type_class.writer ->
  ('a ->
  unit Core.Or_error.t) @ local) @ local

val fill_with_header__local : 
  ([> Core.write ],
    Iobuf__.Iobuf_type_intf.Definitions.no_seek,
    Core.Modes.At_locality.global)
    t @ local ->
  ('a Core.Bin_prot.Size.sizer__local ->
  ('a Core.Bin_prot.Write.writer__local ->
  ('a @ local ->
  unit Core.Or_error.t) @ local) @ local) @ local