package caqti

You can search for identifiers within the package.

in-package search v0.2.0

Unified interface to relational database libraries

Install

dune-project

Dependency

sha256=a363cfcc15f2a3ab9721d08789a65aaa1108d27f974a9b68425a889596e27fb8

sha512=982b9c65fde0405b5d33822ff2743d1c8a8c0611dcd6615dd0af5b32048262f7ddbcae8434193cfd2b7ee845f29c2821d869862b34086099fcffc912b51d61a2

include Caqti_driver_sig.System_common

type +'a future

A concurrency monad with an optional failure monad, or just the identity type constructor for blocking operation.

val (>>=) : 'a future -> ('a -> 'b future) -> 'b future

Bind operation of the concurrency monad.

val (>|=) : 'a future -> ('a -> 'b) -> 'b future

Map operation of the concurrency monad.

val return : 'a -> 'a future

Return operation of the concurrency monad.

val finally : (unit -> 'a future) -> (unit -> unit future) -> 'a future

finally f g runs f () and then runs g () whether the former finished, failed with an exception, or failed with a monadic failure.

val cleanup : (unit -> 'a future) -> (unit -> unit future) -> 'a future

cleanup f g runs f () and then runs g () and re-raise the failure if and only if f () failed with an exception or a monadic failure.

val join : unit future list -> unit future

join ms runs the elements of ms in parallel if supported by the concurrency implementation.

module Mvar : sig ... end

module Log : sig ... end

module Stream : Caqti_stream.S with type 'a future := 'a future

module Unix : sig ... end

module Preemptive : sig ... end