sig
  module To_worker :
    sig
      type ('a, 'b, 'c) t =
          Run of (('a, 'b) Hub.t -> 'c Async.Std.Deferred.t)
    end
  module From_worker : sig type 'a t = Result of 'a | Exn of string end
  val run :
    control_socket:([ `Passive ], Async.Std.Socket.Address.Inet.t)
                   Async.Std.Socket.t ->
    Core.Std.never_returns
end