module type S =sig
..end
type
input
type
output
val compute : ThreadPoolExecutor.t ->
input Stream.t -> output -> output
Then, folds over key/value couple through the reduce operation,
using the third parameter as the inital value.