package ocsigenserver

  1. Overview
  2. Docs
exception Interrupted of exn
exception Cancelled
exception Already_read
exception Finalized
type 'a stream
type !'a step = private
  1. | Finished of 'a stream option
  2. | Cont of 'a * 'a stream
type 'a t
type outcome = [
  1. | `Failure
  2. | `Success
]
val make : ?finalize:(outcome -> unit Lwt.t) -> (unit -> 'a step Lwt.t) -> 'a t
val get : 'a t -> 'a stream
val next : 'a stream -> 'a step Lwt.t
val empty : (unit -> 'a step Lwt.t) option -> 'a step Lwt.t
val cont : 'a -> (unit -> 'a step Lwt.t) -> 'a step Lwt.t
val add_finalizer : 'a t -> (outcome -> unit Lwt.t) -> unit
val finalize : 'a t -> outcome -> unit Lwt.t
val cancel : 'a t -> unit Lwt.t
val consume : 'a t -> unit Lwt.t
exception Stream_too_small
exception Stream_error of string
exception String_too_large
val string_of_stream : int -> string stream -> string Lwt.t
val enlarge_stream : string step -> string step Lwt.t
val stream_want : string step -> int -> string step Lwt.t
val current_buffer : string step -> string
val skip : string step -> int64 -> string step Lwt.t
val substream : string -> string step -> string step Lwt.t
val of_file : string -> string t
val of_string : string -> string t
val of_lwt_stream : 'a Lwt_stream.t -> 'a t
val to_lwt_stream : 'a t -> 'a Lwt_stream.t
module StringStream : sig ... end