search

SeaQL / sea-streamer

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

Fix shared producer #10

Closed tyt2y3 closed 1 year ago

tyt2y3 commented 1 year ago

Previously, when a FileProducer is cloned, dropping any clone would implicitly end the producer. The shared state is now put in an Arc so it only sends Request::Drop when all clones are dropped. Also added a corresponding test case.

tyt2y3 commented 1 year ago

I had a better idea