package caqti-async
Async support for Caqti
Install
Dune Dependency
Authors
Maintainers
Sources
caqti-0.10.2.tbz
sha256=d688bd22f6fde5be5a755900545fade0d5fdce6dbcb0b85770d02dad87c41e7c
md5=d18745a703da336054c0d27e78f8be8a
doc/caqti-async.v1/Caqti1_async/Pool/index.html
Module Caqti1_async.Pool
This is an instantiation of Caqti_pool
for the chosen thread monad.
val create :
?max_size:int ->
?check:('a -> (bool -> unit) -> unit) ->
?validate:('a -> bool Async.Deferred.Or_error.t) ->
(unit -> 'a Async.Deferred.Or_error.t) ->
('a -> unit Async.Deferred.Or_error.t) ->
'a t
(internal) create alloc free
is a pool of resources allocated by alloc
and freed by free
. This is primarily indented for implementing the connect_pool
functions.
val size : 'a t -> int
size pool
is the current number of open resources in pool
.
val use :
?priority:float ->
('a -> 'b Async.Deferred.Or_error.t) ->
'a t ->
'b Async.Deferred.Or_error.t
use f pool
calls f
on a resource drawn from pool
, handing back the resource to the pool when f
exits.
val drain : 'a t -> unit Async.Deferred.Or_error.t
drain pool
closes all resources in pool
. The pool is still usable, as new resources will be created on demand.
sectionYPositions = computeSectionYPositions($el), 10)"
x-init="setTimeout(() => sectionYPositions = computeSectionYPositions($el), 10)"
>