caqti.platform
Caqti_platform.Stream
A stream with monadic concurrency and error handling.
caqti
caqti.blocking
caqti.platform.unix
caqti.plugin
caqti.template
module type FIBER = sig ... end
module Make (Fiber : FIBER) : Caqti_stream_sig.S with type 'a fiber := 'a Fiber.t
Constructs a stream for the provided concurrency monad.