caqti-async

Async support for Caqti
IN THIS PACKAGE
Module Caqti_async . Stream
type ('a, 'err) t = unit -> ( 'a, 'err ) node Async_kernel.Deferred.t
and ('a, 'err) node =
| Nil
| Error of 'err
| Cons of 'a * ( 'a, 'err ) t
val fold : f:( 'a -> 'state -> 'state ) -> ( 'a, 'err ) t -> 'state -> ( 'state, 'err ) result Async_kernel.Deferred.t
val fold_s : f:( 'a -> 'state -> ( 'state, 'err ) result Async_kernel.Deferred.t ) -> ( 'a, 'clog ) t -> 'state -> ( 'state, [> `Congested of 'clog ] as 'err ) result Async_kernel.Deferred.t
val iter_s : f:( 'a -> ( unit, 'err ) result Async_kernel.Deferred.t ) -> ( 'a, 'clog ) t -> ( unit, [> `Congested of 'clog ] as 'err ) result Async_kernel.Deferred.t
val to_rev_list : ( 'a, 'err ) t -> ( 'a list, 'err ) result Async_kernel.Deferred.t
val to_list : ( 'a, 'err ) t -> ( 'a list, 'err ) result Async_kernel.Deferred.t
val of_list : 'a list -> ( 'a, 'err ) t