package octez-libs
Parameters
module H : Hashtbl.HashedType
Signature
include Bare_functor_outputs.Hashtbl.S_ES with type key = H.t
type key = H.t
val create : int -> ('a, 'trace) t
val clear : ('a, 'trace) t -> unit
clear tbl
cancels and removes all the promises in tbl
.
val reset : ('a, 'trace) t -> unit
reset tbl
cancels and removes all the promises in tbl
, and resizes tbl
to its initial size.
val find_or_make :
('a, 'trace) t ->
key ->
(unit -> ('a, 'trace) result Lwt.t) ->
('a, 'trace) result Lwt.t
find_or_make tbl k make
behaves differently depending on k
being bound in tbl
:
- if
k
is bound intbl
thenfind_or_make tbl k make
returns the promisep
thatk
is bound to. Thisp
might be already fulfilled withOk _
or it might be pending. Thisp
cannot be already fulfilled withError _
or already rejected. This is becauseError
/rejected promises are removed from the table automatically. Note however that if thisp
is pending,p
might become fulfilled withError _
or become rejected. - if
k
is not bound intbl
thenmake ()
is called and the returned promisep
is bound tok
intbl
. Thenp
is returned. Whenp
is resolved, it may be removed automatically fromtbl
as described above.
remove tbl k
cancels the promise bound to k
in tbl
and removes it. If k
is not bound in tbl
it does nothing.
val iter_with_waiting_es :
(key -> 'a -> (unit, 'trace) result Lwt.t) ->
('a, 'trace) t ->
(unit, 'trace) result Lwt.t
iter_with_waiting_es f tbl
iterates f
over the bindings in tbl
.
Specifically, for each binding (k, p)
it waits for p
to be fulfilled with Ok v
and calls f k v
. If p
fulfills with Error _
or is rejected, then no call to f
is made for this binding. Note however that an Error
/rejection in one promise returned by f
interrupts the iteration.
It processes bindings one after the other: it waits for both the bound promise to resolve and then the call promise to resolve before continuing to the next binding.
val fold_with_waiting_es :
(key -> 'a -> 'b -> ('b, 'trace) result Lwt.t) ->
('a, 'trace) t ->
'b ->
('b, 'trace) result Lwt.t
fold_with_waiting_es f tbl init
folds init
with f
over the bindings in tbl
.
Specifically, for each binding (k, p)
it waits for p
to be fulfilled with Ok v
and determines the next accumulator by calling f k v acc
. If p
fulfills with Error _
or is rejected, then no call is made for this binding.
It processes bindings one after the other.
fold_promises f tbl init
folds over the table, passing the raw promises to f
. This means that f
can observe Error
/rejections.
This can be used to, e.g., count the number of resolved/unresolved promises.
fold_resolved f tbl init
folds over the already resolved promises of tbl
. More specifically, it folds over the v
for all the promises fulfilled with Ok v
that are bound in tbl
.
val length : ('a, 'trace) t -> int
val stats : ('a, 'trace) t -> Hashtbl.statistics
val iter_with_waiting_ep :
(key -> 'a -> (unit, 'error Trace.trace) result Lwt.t) ->
('a, 'error Trace.trace) t ->
(unit, 'error Trace.trace) result Lwt.t