package kinetic-client

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