package caqti

  1. Overview
  2. Docs
Unified interface to relational database libraries

Install 

dune-project
 Dependency

github.com Readme Changelog Edit opam file Versions (24)

Authors

  1. P
    Petter A. Urkedal <paurkedal@gmail.com>
  2. N
    Nathan Rebours <nathan@cryptosense.com>
  3. B
    Basile Clément

Maintainers

  1. P
    Petter A. Urkedal <paurkedal@gmail.com>

Sources

caqti-v2.3.0.tbz
sha256=4dadf33904c9fd25065dbf6739aa0a9eaaaea000c6981c17a534b475dd5c3891
sha512=13c1cbeff3ee0e54ed1cc8f8df5f7660c292d5d50faa9480916f3c7e578961ab3b3779395c0664346cf42509f7b98d986e8377133542869a462288d6c0e34cbf

doc/caqti.blocking/Caqti_blocking/Stream/index.html

Module Caqti_blocking.StreamSource

Sourcetype ('a, 'err) t = unit -> ('a, 'err) node

A stream, represented as a lazy chain of Cons-nodes terminating in a Nil or an Error.

Sourceand ('a, 'err) node =
  1. | Nil
    (*

    The node of an empty stream

    *)
  2. | Error of 'err
    (*

    A node of a permanently failed stream.

    *)
  3. | Cons of 'a * ('a, 'err) t
    (*

    A node holding the next element and continuation of a stream.

    *)
Sourceval empty : ('a, 'err) t

empty is the empty stream, i.e. it immediately returns Nil.

Sourceval error : 'err -> ('a, 'err) t

error err is a stream which fails immediately with err.

Sourceval fold : f:('a -> 'state -> 'state) -> ('a, 'err) t -> 'state -> ('state, 'err) result

fold ~f stream acc consumes the remainder elements e1, ..., eN of stream and returns Ok (acc |> f e1 |> ... |> f eN) if no error occurred

Sourceval fold_s : f:('a -> 'state -> ('state, 'err) result) -> ('a, 'clog) t -> 'state -> ('state, [> `Congested of 'clog ] as 'err) result

fold_s ~f stream acc consumes the remainder of stream, passing each element in order to f along with the latest accumulation starting at acc, and returning the final accumulation if successful. An error result may be due to either the stream provider or the callback, as distinguished with the `Congested constructor.

Sourceval iter_s : f:('a -> (unit, 'err) result) -> ('a, 'clog) t -> (unit, [> `Congested of 'clog ] as 'err) result

iter_s ~f stream consumes the remainder of stream, passing each element in order to f. An error result may be due to either the steram provider or the callback, as distinguished with the `Congested constructor.

Sourceval to_rev_list : ('a, 'err) t -> ('a list, 'err) result

to_rev_list stream consumes the remainder of stream, returning a list of its element in reverse order of production.

Sourceval to_list : ('a, 'err) t -> ('a list, 'err) result

to_list stream consumes the remainder of stream, returning a list of its element in order of production.

Sourceval of_list : 'a list -> ('a, 'err) t

of_list xs is a non-failing finite stream (re)producing the elements xs in order of occurrence.

Sourceval map_result : f:('a -> ('b, 'err) result) -> ('a, 'err) t -> ('b, 'err) t