0.17.0

0.17.0 (2024-01-24)

Feat

• Middleware capability introduced (#155)

[master 7354fa5] bump: version 0.16.2 → 0.17.0
2 files changed, 8 insertions(+), 2 deletions(-)

0.16.2

0.16.2 (2024-01-23)

Fix

• pyproject.toml: Lock pydantic on > 2.0 because it is not compatible with 1.x since v0.15.2 (#160)

[master 3ae25c3] bump: version 0.16.1 → 0.16.2
2 files changed, 8 insertions(+), 2 deletions(-)

0.16.1

0.16.1 (2024-01-23)

Fix

• coroutine anext introduced for python versions lower than 3.10 (#161)

[master 96fc6ff] bump: version 0.16.0 → 0.16.1
2 files changed, 8 insertions(+), 2 deletions(-)

0.16.0

0.16.0 (2024-01-11)

BREAKING CHANGE

• AsyncGenerator: Stream as async generators (yield from stream) are only available with the new typing approach (#157)

Yield from Stream migration

• Remove the async for in loop inside the stream function. For more details follow the documentation

[master 1938558] bump: version 0.15.2 → 0.16.0
2 files changed, 8 insertions(+), 2 deletions(-)

0.15.2

0.15.2 (2024-01-09)

Refactor

• Updated code to Pydantic 2.0 (get rid of deprecation warnings) (#156)

[master dcf20f5] bump: version 0.15.1 → 0.15.2
2 files changed, 8 insertions(+), 2 deletions(-)

0.15.1

0.15.1 (2023-12-19)

Fix

• Stream: handle errors.ConsumerStoppedError exception for the new consumtion way (#150)

[master 384d0b4] bump: version 0.15.0 → 0.15.1
2 files changed, 8 insertions(+), 2 deletions(-)

0.15.0

0.15.0 (2023-12-18)

Feat

• TestStreamClient: add ability to create extra topics before the test cycle starts (#149)

[master 73819c2] bump: version 0.14.0 → 0.15.0
2 files changed, 8 insertions(+), 2 deletions(-)

0.14.0

0.14.0 (2023-12-14)

Feat

• getmany added to Stream. Closes #128 (#147)

[master ee07b90] bump: version 0.13.1 → 0.14.0
2 files changed, 8 insertions(+), 2 deletions(-)

0.13.1

0.13.1 (2023-12-06)

Fix

• typing: StreamFunc type to match the udf signature. (#142)

[master bb62120] bump: version 0.13.0 → 0.13.1
2 files changed, 8 insertions(+), 2 deletions(-)

0.13.0

0.13.0 (2023-12-06)

Feat

• first steps to add dependency injection. Inspect udf coroutines in order to inject different args on it (#141)
• To iterate a stream is with the async for _ in loop, now it is possible to remove the loop and every time that a new event is in the stream the coroutine function defined by the end user will be awaited. If the stream is also needed, for example because manual commit is enabled then you can also add the stream as an argument in the coroutine. More info here

[master ee1756c] bump: version 0.12.6 → 0.13.0
2 files changed, 8 insertions(+), 2 deletions(-)