package caqti

  1. Overview
  2. Docs

A stream with monadic concurrency and error handling.

module type S = sig ... end
module type FUTURE = sig ... end
module Make (X : FUTURE) : S with type 'a future := 'a X.future

Constructs a stream for the provided concurrency monad.