Module type Command_rpc_intf.T_state_bin_io_only
val rpc : (query, initial_state, update, error) Async.Rpc.State_rpc.t
val implementation : state -> query -> (initial_state * update Async.Pipe.Reader.t, error) Core.Result.t Async.Deferred.t