diff --git a/apps/emqx/src/emqx_rpc.erl b/apps/emqx/src/emqx_rpc.erl index ec8fd83de..961bfd5d6 100644 --- a/apps/emqx/src/emqx_rpc.erl +++ b/apps/emqx/src/emqx_rpc.erl @@ -124,7 +124,7 @@ filter_result(Delivery) -> max_client_num() -> emqx:get_config([rpc, tcp_client_num], ?DefaultClientNum). --spec unwrap_erpc(emqx_rpc:erpc(A)) -> A | {error, _Err}. +-spec unwrap_erpc(emqx_rpc:erpc(A) | [emqx_rpc:erpc(A)]) -> A | {error, _Err} | list(). unwrap_erpc(Res) when is_list(Res) -> [unwrap_erpc(R) || R <- Res]; diff --git a/apps/emqx_management/src/proto/emqx_management_proto_v3.erl b/apps/emqx_management/src/proto/emqx_management_proto_v3.erl index 9c9b71012..937a948e5 100644 --- a/apps/emqx_management/src/proto/emqx_management_proto_v3.erl +++ b/apps/emqx_management/src/proto/emqx_management_proto_v3.erl @@ -45,11 +45,11 @@ introduced_in() -> unsubscribe_batch(Node, ClientId, Topics) -> rpc:call(Node, emqx_mgmt, do_unsubscribe_batch, [ClientId, Topics]). --spec node_info([node()]) -> emqx_rpc:multicall_result(). +-spec node_info([node()]) -> emqx_rpc:erpc_multicall(map()). node_info(Nodes) -> erpc:multicall(Nodes, emqx_mgmt, node_info, [], 30000). --spec broker_info([node()]) -> emqx_rpc:multicall_result(). +-spec broker_info([node()]) -> emqx_rpc:erpc_multicall(map()). broker_info(Nodes) -> erpc:multicall(Nodes, emqx_mgmt, broker_info, [], 30000).