Skip to content

Commit 9b1edd4

Browse files
committed
Fix races in tests
1 parent 323f10b commit 9b1edd4

File tree

1 file changed

+4
-2
lines changed

1 file changed

+4
-2
lines changed

test/gen_stage_test.exs

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -585,7 +585,7 @@ defmodule GenStageTest do
585585
{:ok, doubler} =
586586
Doubler.start_link(
587587
{:producer_consumer, self(),
588-
dispatcher: GenStage.BroadcastDispatcher, subscribe_to: [producer]}
588+
dispatcher: GenStage.BroadcastDispatcher, subscribe_to: [{producer, max_demand: 10}]}
589589
)
590590

591591
{:ok, consumer1} = Forwarder.start_link({:consumer, self()})
@@ -1606,7 +1606,9 @@ defmodule GenStageTest do
16061606
assert_receive {:producer_consumer_subscribed, :consumer, {^consumer, ^ref}}
16071607
Process.unlink(consumer)
16081608
Process.exit(consumer, :kill)
1609-
assert_receive {:producer_consumer_cancelled, {^consumer, ^ref}, {:down, :killed}}
1609+
1610+
assert_receive {:producer_consumer_cancelled, {^consumer, ^ref}, {:down, reason}}
1611+
when reason in [:killed, :noproc]
16101612
end
16111613

16121614
test "consumer handle_subscribe/4" do

0 commit comments

Comments
 (0)