fix: stop properly a stream when it crashes from ExceptionMiddleware

[marcosschroh]

No description provided.

[codecov]

Codecov Report

All modified and coverable lines are covered by tests ✅

Project coverage is 95.59%. Comparing base (c9b1dec) to head (4cd1c2d).

Additional details and impacted files

@@            Coverage Diff             @@
##           master     #189      +/-   ##
==========================================
+ Coverage   94.76%   95.59%   +0.82%     
==========================================
  Files          23       23              
  Lines         860      862       +2     
==========================================
+ Hits          815      824       +9     
+ Misses         45       38       -7     

☔ View full report in Codecov by Sentry.
📢 Have feedback on the report? Share it here.

[woile]

Looks really nice, would it be possible to simulate the behavior in a test?

[marcosschroh]

Looks really nice, would it be possible to simulate the behavior in a test?

There are 2 tests simulating the Stream crash: https://github.com/kpn/kstreams/blob/master/tests/middleware/test_middleware.py#L176-L194. I can add the check that consumer is closed, but thestream is not running