From d4e964f633221903ed4b29bc7b819099af95dbc4 Mon Sep 17 00:00:00 2001 From: JimMoen Date: Tue, 12 Dec 2023 18:37:56 +0800 Subject: [PATCH] refactor: move func section --- .../emqx_gateway_jt808/test/emqx_jt808_SUITE.erl | 16 ++++++++-------- 1 file changed, 8 insertions(+), 8 deletions(-) diff --git a/apps/emqx_gateway_jt808/test/emqx_jt808_SUITE.erl b/apps/emqx_gateway_jt808/test/emqx_jt808_SUITE.erl index 08ba9b8f8..d9200bc9e 100644 --- a/apps/emqx_gateway_jt808/test/emqx_jt808_SUITE.erl +++ b/apps/emqx_gateway_jt808/test/emqx_jt808_SUITE.erl @@ -324,6 +324,14 @@ location_report_28bytes() -> binary_to_hex_string(Data) -> lists:flatten([io_lib:format("~2.16.0B ", [X]) || <> <= Data]). +receive_msg() -> + receive + {deliver, Topic, #message{payload = Payload}} -> + {Topic, Payload} + after 100 -> + {error, timeout} + end. + %%%%%%%%%%%%%%%%%%%%%%%%%%%%% test cases %%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%% t_case00_register(_) -> @@ -2677,11 +2685,3 @@ t_case34_dl_0x8805_single_mm_data_ctrl(_Config) -> {error, timeout} = gen_tcp:recv(Socket, 0, 500), ok = gen_tcp:close(Socket). - -receive_msg() -> - receive - {deliver, Topic, #message{payload = Payload}} -> - {Topic, Payload} - after 100 -> - {error, timeout} - end.