Up

Parameter S : Map_reduce_function_with_init_spec

Signature

type state_type

module Param : Core.Std.Binable

module Accum : Core.Std.Binable

module Input : Core.Std.Binable

val init : Param.t -> state_type Async.Std.Deferred.t

val map : state_type -> Input.t -> Accum.t Async.Std.Deferred.t

val combine : state_type -> Accum.t -> Accum.t -> Accum.t Async.Std.Deferred.t