From 996b205299384a9abb5d4086eb5f3cbda420a077 Mon Sep 17 00:00:00 2001 From: Zaiming Shi Date: Tue, 3 Nov 2020 20:10:13 +0100 Subject: [PATCH] fix(telemetry): Fix dialyzer warning in emqx_telemetry_api --- apps/emqx_telemetry/src/emqx_telemetry_api.erl | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/apps/emqx_telemetry/src/emqx_telemetry_api.erl b/apps/emqx_telemetry/src/emqx_telemetry_api.erl index dfbb42d54..afbc690f4 100644 --- a/apps/emqx_telemetry/src/emqx_telemetry_api.erl +++ b/apps/emqx_telemetry/src/emqx_telemetry_api.erl @@ -103,7 +103,7 @@ get_data(_Bindings, _Params) -> return(get_telemetry_data()). enable_telemetry() -> - [enable_telemetry(Node) || Node <- ekka_mnesia:running_nodes()], ok. + lists:foreach(fun enable_telemetry/1, ekka_mnesia:running_nodes()). enable_telemetry(Node) when Node =:= node() -> emqx_telemetry:enable(); @@ -111,7 +111,7 @@ enable_telemetry(Node) -> rpc_call(Node, ?MODULE, enable_telemetry, [Node]). disable_telemetry() -> - [disable_telemetry(Node) || Node <- ekka_mnesia:running_nodes()], ok. + lists:foreach(fun disable_telemetry/1, ekka_mnesia:running_nodes()). disable_telemetry(Node) when Node =:= node() -> emqx_telemetry:disable(); @@ -128,4 +128,4 @@ rpc_call(Node, Module, Fun, Args) -> case rpc:call(Node, Module, Fun, Args) of {badrpc, Reason} -> {error, Reason}; Result -> Result - end. \ No newline at end of file + end.