sig
  type ('a, 'b, 'c) t
  val create :
    ?init:(Nproc.worker_info -> unit) ->
    int -> ('a -> 'b Lwt.t) -> 'c -> ('a, 'b, 'c) Nproc.Full.t * unit Lwt.t
  val close : ('a, 'b, 'c) Nproc.Full.t -> unit Lwt.t
  val terminate : ('a, 'b, 'c) Nproc.Full.t -> unit
  val submit :
    ('a, 'b, 'c) Nproc.Full.t ->
    f:(('a -> 'b) -> 'c -> 'd -> 'e) -> 'd -> 'e option Lwt.t
  val iter_stream :
    ?granularity:int ->
    ?init:(Nproc.worker_info -> unit) ->
    nproc:int ->
    serv:('a -> 'b Lwt.t) ->
    env:'c ->
    f:(('a -> 'b) -> 'c -> 'd -> 'e) ->
    g:('e option -> unit) -> 'd Stream.t -> unit
end