Close reader

Author: Noarkhh

examples.livemd

@@ -590,6 +590,10 @@ Stream.unfold(%{}, fn _state ->
   Boombox.write(writer, packet)
 
   if :finished in [result1, result2] do
+    if result1 == :ok, do:
+      Boombox.close(writer1)
+    if result2 == :ok, do:
+      Boombox.close(writer2)
     nil
   else
     {nil, %{}}

lib/boombox.ex

@@ -371,7 +371,8 @@ defmodule Boombox do
   end
 
   @doc """
-  Gracefully terminates Boombox when using `:reader` or `:writer` endpoints.
+  Gracefully terminates Boombox when using `:reader` or `:writer` endpoints before a response
+  of type `:finished` has been received.
 
   When using `:reader` endpoint on output informs Boombox that no more packets will be read
   from it with `read/1` and that it should terminate accordingly.

lib/boombox/server.ex

@@ -442,11 +442,6 @@ defmodule Boombox.Server do
     end
   end
 
-  defp elixir_endpoint?({type, _opts}) when type in [:reader, :writer, :message],
-    do: true
-
-  defp elixir_endpoint?(_io), do: false
-
   @spec consuming_boombox_run(boombox_opts(), pid()) :: :ok
   defp consuming_boombox_run(boombox_opts, server_pid) do
     Stream.resource(