Worker (async_iterator.async_iterator.parallel.Async_iterator

module type S = sig ... end

type ('config, 'args, 'message) module_ =
  (module Async_iterator_parallel__.Worker_intf.S
  with type args = 'args
   and type config = 'config
   and type message = 'message)

type ('config, 'args, 'message, 'a) make =
  create_producer:
    ('args ->
      'a Async_iterator.Iterator.Producer.t Core.Or_error.t Async.Deferred.t) ->
  create_consumer:
    ('args ->
      'message Async.Rpc.Pipe_rpc.Direct_stream_writer.t ->
      'a Async_iterator.Iterator.Consumer.t Core.Or_error.t Async.Deferred.t) ->
  bin_args:'args Core.Bin_prot.Type_class.t ->
  bin_message:'message Core.Bin_prot.Type_class.t ->
  ('config, 'args, 'message) module_

module Config : sig ... end

val make : (Config.t, _, _, _) make

alert toplevel [make] depends on [Rpc_parallel.Make], which produces runtime errors if not applied at the toplevel

module For_testing : sig ... end