Rocket.jl Files

Rocket v1.10.0

Diff since v1.9.0

Merged pull requests:

• PR: accumulated() — emit a copy so retained snapshots do not mutate (#82) (@docxology)
• PR: concat — track the active inner subscription so unsubscribe! stops it (#83) (@docxology)
• PR: Fix TimerObservable(==) comparing delay against itself (#84) (@docxology)
• Robustness fixes: merge-after-error, nothing sentinel, file handle, empty input (#85) (@bvdmitri)
• Network/server hardening: bounds-check reads, copy emissions, lock sockets (#86) (@bvdmitri)
• debounce_time: deterministic implementation, tests and docs (#87) (@bvdmitri)
• docs: fix interval example, document generate termination (#88) (@bvdmitri)
• ci: bump GitHub Actions to Node 24 runtimes (#89) (@bvdmitri)

Closed issues:

• Missing scripts folder containing benchmarking and formatting scripts (#60)
• TimerObservable(==) ignores the delay of the right operand (compares delay with itself) (#69)
• merged() keeps emitting values downstream AFTER an inner source errors (#70)
• [MAJOR] concat() unsubscribe does not tear down the active source after the first source completes (#71)
• [MAJOR] network(Vector{T}) reuses one receive buffer -> emitted arrays silently mutate after emission (#72)
• network(Vector{T}) trusts a peer-supplied length -> unbounded unsafe_read into a fixed buffer (#73)
• accumulated() forwards one shared mutable vector -> earlier 'snapshots' silently mutate (#74)
• ServerActor shares its sockets vector unsynchronized across the accept task and broadcasters (#75)
• generate() never checks cancellation -> unbounded CPU/memory after unsubscribe or for infinite conditions (#76)
• nothing used as a 'no value yet' sentinel silently drops real nothing payloads (#77)
• Empty-tuple input: concat(()) throws BoundsError; race(())/zipped(()) silently hang (#78)
• file() leaks the handle and never forwards errors on open/read failure (#79)
• debounce_time() (WIP) silently drops every value; completion never flushes the pending value (#80)
• interval() docstring example contradicts the actual per-subscription counter (#81)