Progress_stream (jenga.Jenga_lib.Rpc_intf.Progress

include sig ... end

module type Version_shared : sig ... end

module Register : functor (Version_i : sig ... end) -> sig ... end

module Register_raw : functor (Version_i : sig ... end) -> sig ... end

val dispatch_multi : Async_rpc_kernel__Versioned_rpc.Connection_with_menu.t ‑> unit ‑> (Progress.Snap.Stable.V1.t Core_kernel.Or_error.t Async_kernel.Pipe.Reader.t * Async_rpc_kernel.Rpc.Pipe_rpc.Metadata.t, Core.Nothing.t) Core_kernel.Result.t Core_kernel.Or_error.t Async_kernel.Deferred.t

val dispatch_iter_multi : Async_rpc_kernel__Versioned_rpc.Connection_with_menu.t ‑> unit ‑> f:(Progress.Snap.Stable.V1.t Async_rpc_kernel.Rpc.Pipe_rpc.Pipe_message.t ‑> Async_rpc_kernel.Rpc.Pipe_rpc.Pipe_response.t) ‑> (Async_rpc_kernel.Rpc.Pipe_rpc.Id.t, Core.Nothing.t) Core_kernel.Result.t Core_kernel.Or_error.t Async_kernel.Deferred.t

val rpcs : unit ‑> Async_rpc_kernel.Rpc.Any.t list

val versions : unit ‑> Core_kernel.Int.Set.t

val name : string