- always subscribe to topics when a Stream is started. Multiple calls to subscribe do not affect the consumer even though it was already subscribed. (191)
0.19.0
Feat
- **structured-concurrency**: first step to introduce structured concurrency paradigm. Now StreamEngine will stop on a Stream crash (only when running with aiorun). Closes 60 due to the use of flag `stop_on_unhandled_errors` with aiorun. Related to 162 (190)
0.18.5
Fix
- stop properly a stream when it crashes from ExceptionMiddleware (189)
0.18.4
Fix
- log possible error in the typed handler wrapper (181)
0.18.3
Fix
- deserializer deprecation warning added. Examples with deserialization updated to middlewares (172)
0.18.2
Fix
- **StreamEngine**: graceful shutdown must wait for all events to be processed before Streams are stopped. Related to 162 (171)