Up – Package index » caqti » Library caqti » Caqti_stream

Module `Caqti_stream`Source

A stream with monadic concurrency and error handling.

Sourcemodule type S = sig ... end

Sourcemodule type FUTURE = sig ... end

Sourcemodule Make (X : FUTURE) : S with type 'a future := 'a X.future

Constructs a stream for the provided concurrency monad.