async
async copied to clipboard
socketry
An awesome asynchronous event-driven reactor for Ruby.
Just for symmetry with `Kernel#Async`. In a library I changed the specs to always run in a `Sync {...}` block which meant I had to change the main reactor from...
#276 introduced a breaking change to the public interface of `Queue`. Prior to #276 `#signal` was inherited from `Notification` where `value` is [defaulted to `nil`](https://github.com/socketry/async/blob/main/lib/async/notification.rb#L13) if it is not provided....
This change allows users to customize how Async handles unhandled exceptions—for example, by logging them to a different destination, adding custom metadata, or forwarding them to an error monitoring service....
Add `cause:` to `Async::Task#stop(cause:)` so that extra information about the **reason** for stopping can be provided. It must be an exception suitable for `raise Async::Stop, cause: cause`. ## Types of...
It can be confusing that a barrier waits on tasks in order rather than in the order of completion/failure, especially if a single failure implies the complete failure of the...
Hi, I'm trying to debug an issue where a call to `statsd.timing` (see https://github.com/reinh/statsd) sometimes hangs when invoked from within an Async task, with latest everything (see environment below). I've...
When a Fiber is stopped by the scheduler, it raise an `Async::Stop` in the Fiber to stop it. However, the backtrace of this exception will be the place where the...
I'm running into an issue when using Async, RubyLLM + VCR. I'm using Async to generate multiple embeddings simultaneously, then attempting to replay using VCR in tests. On the first...
Hi! I'm running into an issue when using Async::Barrier with two infinitely running loops. When I raise a StandardError inside the second task, that task stops, but the barrier continues...
