diff --git a/src/brod_utils.erl b/src/brod_utils.erl index e9b3f83d..78508f83 100644 --- a/src/brod_utils.erl +++ b/src/brod_utils.erl @@ -612,6 +612,7 @@ do_acc(Spawn, Fetcher, Offset, Acc, Fun, [Msg | Rest], End, Count) -> erlang:raise(C, E, Stack) end. +kill_fetcher(undefined) -> ok; kill_fetcher({Pid, Mref}) -> exit(Pid, kill), receive