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.