fix: Websocket connections should be closed on any error

Author: YgorCastor

lib/ex_azure_speech/speech_to_text/websocket.ex

@@ -105,6 +105,10 @@ defmodule ExAzureSpeech.SpeechToText.Websocket do
          {:ok, _} <- update_connection_context(pid),
          {:ok, _} <- start_stream(pid) do
       {:ok, stream_responses(pid, close_connection_callback)}
+    else
+      err ->
+        close_connection_callback.(pid)
+        err
     end
   end
 

lib/ex_azure_speech/text_to_speech/websocket.ex

@@ -115,6 +115,10 @@ defmodule ExAzureSpeech.TextToSpeech.Websocket do
          {:ok, _} <- update_connection_context(pid),
          {:ok, _} <- start_synthesis(pid, command) do
       {:ok, stream_responses(pid, close_connection_callback)}
+    else
+      err ->
+        close_connection_callback.(pid)
+        err
     end
   end