- check whether Stream is running when TestStreamClient is leaving the context. This allows to send more events after a Stream has crashed and still the TestStreamClient will be able to leave the context without hanging (204)
0.22.0
Feat
- add Send type hint parameter to udf when a Stream is defined (202)
0.21.0
Feat
- subscribe topics by pattern (199)
0.20.0
Feat
- StreamEngine hooks on_startup, on_stop, after_startup and after_stop added (193)