package caqti

  1. Overview
  2. Docs

Module Caqti_streamSource

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.