zalky / cues

Queues on cue: low-latency persistent blocking queues, processors, and graphs via Chronicle Queue
Apache License 2.0
105 stars 2 forks source link

Fix #2 Ensure all watches removed after non-blocking alts read #5

Closed zalky closed 1 year ago

zalky commented 1 year ago

Fixes #2

Updates cues.queue/alts to remove all watches on a successful read. Failing to remove watches incurs a minor alts performance penalty in cases where tailers are repeatedly being created and destroyed. Does not affect behaviour of queues and tailers otherwise.