Module `Iostream.In`Source

Input stream.

Sourcetype t = private {

input : bytes -> int -> int -> int;
(*
Read into the slice. Returns 0 only if the stream is closed.
*)
close : unit -> unit;
(*
Close the input. Must be idempotent.
*)
as_fd : unit -> Unix.file_descr option;
(*
Cast into a file descriptor, if it actually is a direct wrapper of a Unix FD.
*)

}

An input stream, i.e an incoming stream of bytes.

This can be a string, an int_channel, an Unix.file_descr, a decompression wrapper around another input stream, etc.

val create : 
  ?as_fd:(unit -> Unix.file_descr option) ->
  ?close:(unit -> unit) ->
  input:(bytes -> int -> int -> int) ->
  unit ->
  t

Sourceval empty : t

Empty input, contains 0 bytes.

Sourceval of_unix_fd : ?close_noerr:bool -> Unix.file_descr -> t

Create an in stream from a raw Unix file descriptor. The file descriptor must be opened for reading.

Sourceval of_in_channel : ?close_noerr:bool -> in_channel -> t

Wrap a standard input channel.

Sourceval open_file : ?mode:int -> ?flags:Unix.open_flag list -> string -> t

val with_open_file : 
  ?mode:int ->
  ?flags:Unix.open_flag list ->
  string ->
  (t -> 'a) ->
  'a

Sourceval of_string : ?off:int -> ?len:int -> string -> t

An input channel reading from the string.

parameter len
the length of the slice we read from. Default String.length s - off.

Sourceval of_bytes : ?off:int -> ?len:int -> bytes -> t

An input channel reading from the bytes buffer. See of_string for more details.

Sourceval input : t -> bytes -> int -> int -> int

Read bytes into the given buffer. This returns 0 only if the stream has reached its end.

Sourceval concat : t list -> t

Read from each stream, in order

Sourceval seek : t -> int -> unit

If available, seek in the underlying stream.

Sourceval pos : t -> int

If available, return current offset in underlying stream.

Sourceval close : t -> unit

Close the input stream. This is idempotent.

Sourceval copy_into : ?buf:bytes -> t -> Out.t -> unit

Copy the whole stream into the given output.

Sourceval map_char : (char -> char) -> t -> t

Transform the stream byte by byte

package iostream