From 5b63a9a304e7974590d4af10f68519ec716583a8 Mon Sep 17 00:00:00 2001 From: vkatsuba Date: Wed, 20 Oct 2021 00:41:09 +0300 Subject: [PATCH] io --- big_tests/tests/rest_client_SUITE.erl | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/big_tests/tests/rest_client_SUITE.erl b/big_tests/tests/rest_client_SUITE.erl index 6dddf12f452..26c173f53b4 100644 --- a/big_tests/tests/rest_client_SUITE.erl +++ b/big_tests/tests/rest_client_SUITE.erl @@ -1026,14 +1026,14 @@ connect_to_sse(User) -> #{pid => ConnPid, stream_ref => StreamRef}. wait_for_event(#{pid := Pid, stream_ref := StreamRef} = Opts) -> - case gun:await(Pid, StreamRef) of - {response, nofin, _, _} -> + case gun:await(Pid, StreamRef, 5000) of + {response, nofin, _, _} = A -> io:format("await_1 ~p~n", [A]), wait_for_event(Opts); - {data, nofin, _} -> + {data, nofin, _} = A -> io:format("await_2 ~p~n", [A]), wait_for_event(Opts); - {sse, #{data := [Response]}} -> + {sse, #{data := [Response]}} = A -> io:format("await_3 ~p~n", [A]), Opts#{data => Response}; - Error -> + Error -> io:format("await_error ~p~n", [Error]), Error end.