Handle Consumer closing

[Gsantomaggio]

fixes #57
fixes #60

[codecov-commenter]

Codecov Report

Merging #58 (4d9ac35) into main (89ba0a8) will increase coverage by 3.52%.
The diff coverage is 89.74%.

@@            Coverage Diff             @@
##             main      #58      +/-   ##
==========================================
+ Coverage   74.94%   78.47%   +3.52%     
==========================================
  Files          16       16              
  Lines        1956     1979      +23     
==========================================
+ Hits         1466     1553      +87     
+ Misses        395      330      -65     
- Partials       95       96       +1     

Impacted Files	Coverage Δ
pkg/stream/constants.go	78.43% <ø> (ø)
pkg/stream/dialer_posix.go	53.84% <ø> (ø)
pkg/stream/client.go	77.65% <62.50%> (+0.17%)	⬆️
pkg/stream/producer.go	81.15% <80.00%> (+1.64%)	⬆️
pkg/stream/brokers.go	94.52% <100.00%> (+13.69%)	⬆️
pkg/stream/consumer.go	82.85% <100.00%> (+1.46%)	⬆️
pkg/stream/coordinator.go	94.35% <100.00%> (+0.06%)	⬆️
pkg/stream/enviroment.go	76.58% <100.00%> (+12.84%)	⬆️
pkg/stream/server_frame.go	68.96% <100.00%> (+2.52%)	⬆️
pkg/stream/socket.go	76.47% <0.00%> (-5.89%)	⬇️
... and 5 more

---

Continue to review full report at Codecov.

Legend - Click here to learn more
Δ = absolute <relative> (impact), ø = not affected, ? = missing data
Powered by Codecov. Last update 89ba0a8...4d9ac35. Read the comment docs.