Module Command.ConnSource

Sourcemodule IO : sig ... end
Sourcetype t = {
  1. ic : IO.ic;
  2. oc : IO.oc;
  3. buffer : bytes;
}
Sourceval v : ?buffer_size:int -> IO.ic -> IO.oc -> t

Create a new connection using flow, ic and oc

Sourceval is_closed : t -> bool

Check if the underlying channel is closed

Read the next message

Sourceval write : t -> 'a Irmin.Type.t -> 'a -> unit Lwt.t

Write a message

Sourceval ok : t -> unit Lwt.t

Send "OK" message with unit response

Sourceval err : t -> string -> unit Lwt.t

Send error message

Sourcemodule Handshake : sig ... end
Sourcemodule Request : sig ... end
Sourcemodule Response : sig ... end
Sourcemodule Return : sig ... end