Merge pull request #79 from membraneframework/jb/propagate-end-of-stream

Propagate end of stream
membraneframework · Dec 11, 2023 · f9fc845 · f9fc845
2 parents 58d8659 + a8794bc
commit f9fc845
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 6 deletions.
diff --git a/README.md b/README.md
@@ -14,7 +14,7 @@ The package can be installed by adding `membrane_rtmp_plugin` to your list of de
 ```elixir
 def deps do
   [
-	  {:membrane_rtmp_plugin, "~> 0.19.1"}
+	  {:membrane_rtmp_plugin, "~> 0.19.2"}
   ]
 end
 ```

diff --git a/lib/membrane_rtmp_plugin/rtmp/source/source.ex b/lib/membrane_rtmp_plugin/rtmp/source/source.ex
@@ -222,10 +222,10 @@ defmodule Membrane.RTMP.Source do
 
   @impl true
   def handle_info({:socket_closed, _socket}, ctx, state) do
-    cond do
-      ctx.pads.output.end_of_stream? -> {[], state}
-      ctx.pads.output.start_of_stream? -> {[end_of_stream: :output], state}
-      true -> {[notify_parent: :unexpected_socket_closed], state}
+    if ctx.pads.output.end_of_stream? do
+      {[], state}
+    else
+      {[notify_parent: :unexpected_socket_closed, end_of_stream: :output], state}
     end
   end
 

diff --git a/mix.exs b/mix.exs
@@ -1,7 +1,7 @@
 defmodule Membrane.RTMP.Mixfile do
   use Mix.Project
 
-  @version "0.19.1"
+  @version "0.19.2"
   @github_url "https://github.com/membraneframework/membrane_rtmp_plugin"
 
   def project do