Module Body.ReaderSource

Sourcetype t = {
  1. faraday : Faraday.t;
  2. mutable read_scheduled : bool;
  3. mutable on_eof : unit -> unit;
  4. mutable on_read : Bigstringaf.t -> off:int -> len:int -> unit;
  5. buffered_bytes : int ref;
  6. done_reading : int -> unit;
}
Sourceval default_done_reading : int -> unit
Sourceval default_on_eof : unit -> unit
Sourceval default_on_read : Bigstringaf.t -> off:int -> len:int -> unit
Sourceval create : Faraday.bigstring -> done_reading:(int -> unit) -> t
Sourceval create_empty : unit -> t
Sourceval empty : t
Sourceval is_closed : t -> bool
Sourceval unsafe_faraday : t -> Faraday.t
Sourceval do_execute_read : t -> (unit -> unit) -> (Faraday.bigstring -> off:int -> len:int -> unit) -> unit
Sourceval execute_read : t -> unit
Sourceval schedule_read : t -> on_eof:(unit -> unit) -> on_read:(Bigstringaf.t -> off:int -> len:int -> unit) -> unit
Sourceval close : t -> unit
Sourceval has_pending_output : t -> bool