Async::Tools

A set of useful Async tools.

Add this line to your application's Gemfile:

gem 'async-tools'

And then execute:

$ bundle install

Or install it yourself as:

$ gem install async-tools

More docs coming soon.

A drop-in replacement for Async::Queue and Async::LimitedQueue. Can work as limited or unlimited queue depending on initializer arguments. Supports mode switching and scaling in both directions.

A thin wrapper around Async::Q that acts like a Go channel. Can be user for delivering messages and exceptions(using #error method). Exceptions are being reraised in #dequeue, #each and #async. Can be closed. After being closed automatically stops accepting new messages and schedules graceful stop of all consumers. Awaiing #each or #async will return, #dequeue will raise ChannelClosedError. In compare to Async::Queue, Async::LimitedQueue and Async:Q, Async::Channel can send nil's.

A thin wrapper around Async::Channel and Async::Semaphore. WorkerPool can be used to perform concurrent actions with limited strictly limited concurrency.

After checking out the repo, run bin/setup to install dependencies. Then, run rake spec to run the tests. You can also run bin/console for an interactive prompt that will allow you to experiment.

To install this gem onto your local machine, run bundle exec rake install. To release a new version, update the version number in version.rb, and then run bundle exec rake release, which will create a git tag for the version, push git commits and the created tag, and push the .gem file to rubygems.org.

Bug reports and pull requests are welcome on GitHub at https://github.com/[USERNAME]/async-tools. This project is intended to be a safe, welcoming space for collaboration, and contributors are expected to adhere to the code of conduct.

The gem is available as open source under the terms of the MIT License.

Everyone interacting in the Async::Tools project's codebases, issue trackers, chat rooms and mailing lists is expected to follow the code of conduct.