Have a dummy producer for use during tests

[dashbitco]

Have a dummy producer for use during tests

[wojtekmach]

Regarding the note about test_message using transformer, that still needs to be done:

diff --git a/test/broadway_test.exs b/test/broadway_test.exs
index 88e546c..4edb410 100644
--- a/test/broadway_test.exs
+++ b/test/broadway_test.exs
@@ -649,13 +649,16 @@ defmodule BroadwayTest do
 
       producer = get_producer(broadway_name, :default)
 
-      %{producer: producer}
+      %{broadway: broadway_name, producer: producer}
     end
 
-    test "transform all events" do
+    test "transform all events", context do
       assert_receive {:message_handled, "1 transformed"}
       assert_receive {:message_handled, "2 transformed"}
       assert_receive {:message_handled, "3 transformed"}
+
+      Broadway.test_messages(context.broadway, [4])
+      assert_receive {:message_handled, "3 transformed"}
     end
 
     @tag events: [1, 2, :kill_producer, 4]

fails:

  1) test transformer transform all events (BroadwayTest)
     test/broadway_test.exs:655
     No message matching {:message_handled, "4 transformed"} after 100ms.
     Process mailbox:
       {:batch_handled, :default, [%Broadway.Message{acknowledger: {BroadwayTest.Acker, :ack_ref, %{id: 1, test_pid: #PID<0.201.0>}}, batch_key: :default, batcher: :default, data: "1 transformed", metadata: %{}, status: :ok}, %Broadway.Message{acknowledger: {BroadwayTest.Acker, :ack_ref, %{id: 2, test_pid: #PID<0.201.0>}}, batch_key: :default, batcher: :default, data: "2 transformed", metadata: %{}, status: :ok}]}
       {:ack, [%Broadway.Message{acknowledger: {BroadwayTest.Acker, :ack_ref, %{id: 1, test_pid: #PID<0.201.0>}}, batch_key: :default, batcher: :default, data: "1 transformed", metadata: %{}, status: :ok}, %Broadway.Message{acknowledger: {BroadwayTest.Acker, :ack_ref, %{id: 2, test_pid: #PID<0.201.0>}}, batch_key: :default, batcher: :default, data: "2 transformed", metadata: %{}, status: :ok}], []}
       {:message_handled, 4}
       {:batch_handled, :default, [%Broadway.Message{acknowledger: {BroadwayTest.Acker, :ack_ref, %{id: 3, test_pid: #PID<0.201.0>}}, batch_key: :default, batcher: :default, data: "3 transformed", metadata: %{}, status: :ok}, %Broadway.Message{acknowledger: {Broadway.CallerAcknowledger, {#PID<0.201.0>, #Reference<0.2326357567.4112252929.5071>}, :ok}, batch_key: :default, batcher: :default, data: 4, metadata: %{}, status: :ok}]}
       {:ack, #Reference<0.2326357567.4112252929.5071>, [%Broadway.Message{acknowledger: {Broadway.CallerAcknowledger, {#PID<0.201.0>, #Reference<0.2326357567.4112252929.5071>}, :ok}, batch_key: :default, batcher: :default, data: 4, metadata: %{}, status: :ok}], []}
       {:ack, [%Broadway.Message{acknowledger: {BroadwayTest.Acker, :ack_ref, %{id: 3, test_pid: #PID<0.201.0>}}, batch_key: :default, batcher: :default, data: "3 transformed", metadata: %{}, status: :ok}], []}
     code: assert_receive {:message_handled, "4 transformed"}
     stacktrace:
       test/broadway_test.exs:661: (test)