package kinetic-client

  1. Overview
  2. Docs
val _decode_fixed32 : Bytes.t -> int -> int
val _encode_fixed32 : bytes -> int -> int -> unit
val read_exact_generic : ('b -> 'a -> int -> int -> int Lwt.t) -> 'b -> 'a -> int -> int -> unit Lwt.t
val write_exact_generic : ('b -> 'a -> int -> int -> int Lwt.t) -> 'b -> 'a -> int -> int -> unit Lwt.t
val maybe_read_generic : (int -> 'a) -> ('b -> 'a -> int -> int -> int Lwt.t) -> 'b -> int -> 'a option Lwt.t
val network_receive_generic : timeout:float -> (int -> 'a) -> ('b -> 'a -> int -> int -> int Lwt.t) -> ('b -> bytes -> int -> int -> int Lwt.t) -> 'b -> ('b -> string) -> bool -> (Kinetic_types.message * 'a option * bytes, Kinetic_error.Error.t) result Lwt.t
val network_send_generic : ('a -> 'b -> int -> int -> int Lwt.t) -> ('a -> bytes -> int -> int -> int Lwt.t) -> 'a -> Bytes.t -> ('b * int * int) option -> ('a -> string) -> bool -> unit Lwt.t
OCaml

Innovation. Community. Security.