Skip to content

Commit 4ad175f

Browse files
authored
Merge pull request #362 from zmstone/master
Handle undefined fetcher in fold loop exception
2 parents a8d243d + 440f9d1 commit 4ad175f

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

src/brod_utils.erl

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -612,6 +612,7 @@ do_acc(Spawn, Fetcher, Offset, Acc, Fun, [Msg | Rest], End, Count) ->
612612
erlang:raise(C, E, Stack)
613613
end.
614614

615+
kill_fetcher(undefined) -> ok;
615616
kill_fetcher({Pid, Mref}) ->
616617
exit(Pid, kill),
617618
receive

0 commit comments

Comments
 (0)