diff --git a/rebar.config b/rebar.config index 41e3a8f..58aea7b 100644 --- a/rebar.config +++ b/rebar.config @@ -54,7 +54,7 @@ {alias, [{test, [format, lint, xref, dialyzer, eunit, cover, edoc]}]}. {plugins, [ - {rebar3_format, "~> 0.5.0"}, + {rebar3_format, "~> 0.6.0"}, rebar3_lint, rebar3_hex ]}. diff --git a/test/kinetic_stream_tests.erl b/test/kinetic_stream_tests.erl index 6703929..1ac2995 100644 --- a/test/kinetic_stream_tests.erl +++ b/test/kinetic_stream_tests.erl @@ -65,8 +65,8 @@ test_get_stream() -> ok; _ -> bad - after 1000 -> - bad + after 1000 -> + bad end, ets:insert_new(?KINETIC_STREAM, {<<"mystream">>, ChildPid}), pid = kinetic_stream:get_stream(<<"mystream">>, {<<"whatever">>}). @@ -114,9 +114,8 @@ test_functionality() -> [{<<"Data">>, b64fast:encode64(RegularData)}, {<<"PartitionKey">>, <
>}, {<<"StreamName">>, S}], - receive - after 100 -> - ok + receive after 100 -> + ok end, true = meck:called(kinetic, put_record, [Payload2, Pid]), kinetic_stream:flush(S, {P}), @@ -156,6 +155,6 @@ wait_for_flush() -> ok; _ -> bad - after 1000 -> - bad + after 1000 -> + bad end.