Up
Module
Worker
:
Worker
with
type
param_type
=
Param.t
and
type
run_input_type
= [
| `Map
of
Input.t
| `Combine
of
Accum.t
*
Accum.t
| `Map_right_combine
of
Accum.t
*
Input.t
]
and
type
run_output_type
=
Accum.t
Signature
type
t
type
param_type =
Param.t
type
run_input_type = [
| `Map
of
Input.t
| `Combine
of
Accum.t
*
Accum.t
| `Map_right_combine
of
Accum.t
*
Input.t
]
type
run_output_type =
Accum.t
val
spawn_config_exn :
Config.t
->
param_type
->
t
list
Async.Std.Deferred.t
val
run_exn :
t
->
run_input_type
->
run_output_type
Async.Std.Deferred.t
val
shutdown_exn :
t
-> unit
Async.Std.Deferred.t