package mirage-channel

  1. Overview
  2. Docs

Module Mirage_channel.MakeSource

Functor to create a CHANNEL from a flow implementation

Parameters

module F : Mirage_flow.S

Signature

Sourcetype error

The type for errors.

Sourceval pp_error : error Fmt.t

pp_error is the pretty-printer for errors.

Sourcetype write_error = private [>
  1. | Mirage_flow.write_error
]

The type for write errors.

Sourceval pp_write_error : write_error Fmt.t

pp_write_error is the pretty-printer for write errors.

Sourcetype flow = F.flow

The type for unbuffered network flow.

Sourcetype t

The type for the state associated with channels, such as the inflight buffers.

Sourceval create : flow -> t

create flow allocates send and receive buffers and associates them with the given unbuffered flow.

Sourceval to_flow : t -> flow

to_flow t returns the flow that backs this channel.

Sourceval read_char : t -> (char Mirage_flow.or_eof, error) result Lwt.t

Reads a single character from the channel, blocking if there is no immediately available input data.

Sourceval read_some : ?len:int -> t -> (Cstruct.t Mirage_flow.or_eof, error) result Lwt.t

read_some ?len t reads up to len characters from the input channel and at most a full buffer. If len is not specified, it reads all available data and returns that buffer.

Sourceval read_exactly : len:int -> t -> (Cstruct.t list Mirage_flow.or_eof, error) result Lwt.t

read_exactly len t reads len bytes from the channel t or fails with Eof.

read_line t reads a line of input, which is terminated either by a CRLF sequence, or the end of the channel (which counts as a line).

  • returns

    Returns a list of views that terminates at EOF.

Sourceval write_char : t -> char -> unit

write_char t ch writes a single character to the output channel.

Sourceval write_string : t -> string -> int -> int -> unit

write_string t buf off len writes len bytes from a string buf, starting from from offset off.

Sourceval write_buffer : t -> Cstruct.t -> unit

write_buffer t buf copies the buffer to the channel's output buffer. The buffer should not be modified after being written, and it will be recycled into the buffer allocation pool at some future point.

Sourceval write_line : t -> string -> unit

write_line t buf writes the string buf to the output channel and append a newline character afterwards.

Sourceval flush : t -> (unit, write_error) result Lwt.t

flush t flushes the output buffer and block if necessary until it is all written out to the flow.

Sourceval close : t -> (unit, write_error) result Lwt.t

close t calls flush and then close the underlying flow.