search

faust-streaming / faust

Python Stream Processing. A Faust fork
https://faust-streaming.github.io/faust/
Other
1.66k stars 183 forks source link

Add on_clear handlers to (Global)Table and ChangeloggedSet #645

Closed egao1980 closed 2 weeks ago

egao1980 commented 1 month ago

Description

Adding on_clear handlers.

Table and GlobalTable share implementation that runs on_key_del handler for each key currently stored in the table before cleaning the dictionary.

ChangeloggedSet is using existing OPERATION_UPDATE event with current values as a removed values set.

Fixes #601