Module Caqti_platform.StreamSource

A stream with monadic concurrency and error handling.

Sourcemodule type FIBER = sig ... end
Sourcemodule Make (Fiber : FIBER) : Caqti_stream_sig.S with type 'a fiber := 'a Fiber.t

Constructs a stream for the provided concurrency monad.