Ryu
view release on metacpan or search on metacpan
3.005 2024-01-04 04:21:40+08:00 Asia/Singapore
[Bugs fixed]
- handle the `max_items` parameter to `->as_queue`
[Dependencies]
- update to latest Future::Queue to avoid deep-recursion scenario
3.004 2023-03-05 14:36:17+08:00 Asia/Singapore
[New features]
- Ryu::Source->as_queue allows `max_items` and will pause the stream while waiting for the queue to drain
- flag a warning when someone tries to use `->completed->done/fail` directly, since that's not likely to work as expected
[Bugs fixed]
- extra single-use Futures were being created, which caused complaints from Future::XS since they were
abandoned (the ->without_cancel calls in Ryu::Node)
- chained nodes were still being called after completion, which would lead to some odd-looking debug messages
from nodes such as `->take(5)`
3.003 2023-03-03 20:51:58+08:00 Asia/Singapore
[New features]
- Ryu::Observable now has a ->finish method
3.002 2021-07-07 17:48:25+08:00 Asia/Kuala_Lumpur
[Bugs fixed]
- in ->flat_map, any failure in the original or added Ryu::Source instances
will now propagate as a failure for the ->flat_map source as well
3.001 2021-06-21 08:19:28+08:00 Asia/Kuala_Lumpur
[New features]
- Ryu::Observable has aliases for ->as_numeric, ->as_number and ->set_numeric, ->set_number
- Sentinel support for Ryu::Observable via ->lvalue_str and ->lvalue_num
3.000 2021-05-01 19:58:23+08:00 Asia/Kuala_Lumpur
[New features]
- ->next support
[Bugs fixed]
- the ->completed and ->unblocked methods now return uncancellable Futures, so that
they can be used with constructs such as Future->wait_any(timeout, $src->unblocked)
without affecting internal state
2.009 2021-04-13 13:32:36+08:00 Asia/Kuala_Lumpur
No new features.
Bugs fixed:
- ->unblocked could fail due to bypassing the default when attempting to use the Future factory
2.008 2021-04-05 12:20:04+08:00 Asia/Kuala_Lumpur
New features:
- ->emit_from joins multiple sources into the current source
2.007 2021-01-25 02:01:08+08:00 Asia/Kuala_Lumpur
New features:
- the `->source` provided by a Ryu::Sink is now a child of the sink itself,
to facilitate backpressure algorithms and help with common streaming configurations
Bugs fixed:
- ->ordered_futures would call ->pause or ->resume more often than required,
these are now only triggered when they would change state
2.006 2021-01-17 03:02:18+08:00 Asia/Kuala_Lumpur
New features:
- ->ordered_futures (->resolve) now also takes low/high parameters for backpressure
Bugs fixed:
- original source failure propagates after any pending Future instances are resolved,
thanks to Amin Marashi (Github issue #8)
2.005 2021-01-17 02:16:18+08:00 Asia/Kuala_Lumpur
New features:
- ->as_buffer can take low/high parameters similar to ->buffer, providing backpressure
for buffer streams.
Bugs fixed:
- small amount of extra protection on Ryu::Observable->notify_all, which was
previously passing an alias to the internal value (so the notifier callback
was able to modify this directly). Now receives a copy.
Documentation updates:
- Mojo::Rx no longer exists, replaced with RxPerl references
2.004 2020-12-03 00:38:42+08:00 Asia/Kuala_Lumpur
No new features.
Bugs fixed:
- the `->from` method on a source was trying to call `blessed()` without importing
it (thanks to KARJALA for raising this one)
2.003 2020-08-04 11:50:48+08:00 Asia/Kuala_Lumpur
No new features.
Bugs fixed:
- memory leak when using ->ordered_futures, due to accumulation of callbacks for
cancelling pending requests (thanks to Nael Alolwani for reporting and providing
a test case)
2.002 2020-06-27 23:53:40+08:00 Asia/Kuala_Lumpur
No new features.
Documentation updates:
- mention RxPerl and Future::Buffer
- clearer link to Ryu::Source, since it's not always obvious
where the real code can be found...
2.001 2020-06-09 01:35:39+08:00 Asia/Kuala_Lumpur
New features:
( run in 0.828 second using v1.01-cache-2.11-cpan-d8267643d1d )