0.21.0

0.21.0 (2024-07-16)

Feat

• subscribe topics by pattern (#199)

[master 9cb889f] bump: version 0.20.0 → 0.21.0
2 files changed, 8 insertions(+), 2 deletions(-)

0.20.0

0.20.0 (2024-07-04)

Feat

• StreamEngine hooks on_startup, on_stop, after_startup and after_stop added (#193)

[master 7d2e0e1] bump: version 0.19.1 → 0.20.0
2 files changed, 8 insertions(+), 2 deletions(-)

0.19.1

0.19.1 (2024-07-03)

Fix

• 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)

[master 063b2e6] bump: version 0.19.0 → 0.19.1
2 files changed, 8 insertions(+), 2 deletions(-)

0.19.0

0.19.0 (2024-07-01)

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)

[master 37dd34d] bump: version 0.18.5 → 0.19.0
2 files changed, 8 insertions(+), 2 deletions(-)

0.18.5

0.18.5 (2024-06-20)

Fix

• stop properly a stream when it crashes from ExceptionMiddleware (#189)

[master 78032d2] bump: version 0.18.4 → 0.18.5
2 files changed, 8 insertions(+), 2 deletions(-)

0.18.4

0.18.4 (2024-05-14)

Fix

• log possible error in the typed handler wrapper (#181)

[master e866dfd] bump: version 0.18.3 → 0.18.4
2 files changed, 8 insertions(+), 2 deletions(-)

0.18.3

0.18.3 (2024-02-12)

Fix

• deserializer deprecation warning added. Examples with deserialization updated to middlewares (#172)

[master 1cfa098] bump: version 0.18.2 → 0.18.3
2 files changed, 8 insertions(+), 2 deletions(-)

0.18.2

0.18.2 (2024-02-08)

Fix

• StreamEngine: graceful shutdown must wait for all events to be processed before Streams are stopped. Related to #162 (#171)

[master 2a0732c] bump: version 0.18.1 → 0.18.2
2 files changed, 8 insertions(+), 2 deletions(-)

0.18.1

0.18.1 (2024-01-31)

Fix

• make sure that there is not an asyncio.Task when udf is an async generators. Middleware repr added. (#167)

[master 4b3f975] bump: version 0.18.0 → 0.18.1
2 files changed, 8 insertions(+), 2 deletions(-)

0.18.0

0.18.0 (2024-01-29)

Feat

• TestStreamClient: support custom classes for test consumers and producers

[master 5f39345] bump: version 0.17.2 → 0.18.0
2 files changed, 8 insertions(+), 2 deletions(-)