diff --git a/README.md b/README.md index dd8d10e7..ad3272b0 100644 --- 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 index 13a77da3..86e2a4ce 100644 --- 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 index 0b9e9e34..0dde73cb 100644 --- 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