Fix test, rename file

membraneframework · Nov 20, 2024 · 54313bb · 54313bb
1 parent 45f99bd
commit 54313bb
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/lib/membrane/forwarding_filter.ex → lib/membrane/connector.ex b/lib/membrane/forwarding_filter.ex → lib/membrane/connector.ex
diff --git a/test/membrane/integration/connector_test.exs b/test/membrane/integration/connector_test.exs
@@ -41,11 +41,11 @@ defmodule Membrane.Integration.ConnectorTest do
       Testing.Pipeline.notify_child(pipeline, :source, {type, item})
 
       if type in [:stream_format, :event] do
-        assert_pipeline_notified(pipeline, :filter, {^type, Pad.ref(:input, _id), ^item})
+        assert_pipeline_notified(pipeline, :connector, {^type, Pad.ref(:input, _id), ^item})
       end
     end)
 
-    spec = get_child(:filter) |> child(:sink, Testing.Sink)
+    spec = get_child(:connector) |> child(:sink, Testing.Sink)
     Testing.Pipeline.execute_actions(pipeline, spec: spec)
 
     data
@@ -62,7 +62,7 @@ defmodule Membrane.Integration.ConnectorTest do
       Testing.Pipeline.notify_child(pipeline, :source, {type, item})
 
       if type in [:stream_format, :event] do
-        assert_pipeline_notified(pipeline, :filter, {^type, Pad.ref(:input, _id), ^item})
+        assert_pipeline_notified(pipeline, :connector, {^type, Pad.ref(:input, _id), ^item})
       end
 
       case type do