Module Colombe.StateSource

Sourcetype ('a, 'err) t =
  1. | Read of {
    1. buffer : bytes;
    2. off : int;
    3. len : int;
    4. k : [ `End | `Len of int ] -> ('a, 'err) t;
    }
  2. | Write of {
    1. buffer : string;
    2. off : int;
    3. len : int;
    4. k : int -> ('a, 'err) t;
    }
  3. | Return of 'a
  4. | Error of 'err
Sourceval reword_error : ('a -> 'b) -> ('v, 'a) t -> ('v, 'b) t
Sourceval join : (('a, 'err) t, 'err) t -> ('a, 'err) t
Sourceval to_result : ('a, 'err) t -> (('a, 'err) result, _) t
Sourcemodule Context : sig ... end
Sourcemodule type S = sig ... end
Sourcemodule type C = sig ... end
Sourcemodule Scheduler (Context : C) (Value : S with type encoder = Context.encoder and type decoder = Context.decoder) : sig ... end