search

SeaQL / sea-streamer

🌊 A real-time stream processing toolkit for Rust
https://www.sea-ql.org/SeaStreamer/
Apache License 2.0
238 stars 7 forks source link

Fix shared producer #11

Closed tyt2y3 closed 10 months ago

tyt2y3 commented 10 months ago

Previously, when a FileProducer is cloned, dropping any clone would implicitly end the producer. The fix is, when we clone a producer, we should increment the shared counter. Also added a corresponding test case.