Worker.Shutdown_ontype !'a t = 'a Rpc_parallel__Parallel.Make(T).Shutdown_on(M).t = | Connection_closed : ( connection_state_init_arg:T.Connection_state.init_arg ->
Connection.t M.t Async.Deferred.t )
t |
| Heartbeater_connection_timeout : worker M.t Async.Deferred.t t |
| Called_shutdown_function : worker M.t Async.Deferred.t t |