Contributors

Usage

require'em/throttled_queue'# Example code that will pop off 2 items in total within a period of
# one second. The other items are not popped because of throttle.
EM::rundo# Create a queue that will pop off maximum of 2 items per second.
queue=EM::ThrottledQueue.new(2)queue.push1# you can push one item at a time
queue.push2,3,4,5,6# or several at once
5.times{queue.pop(&EM::Callback(Object,:puts))}EM::add_timer(1){EM::stop}end# Output:
# 1
# 2

Installation

How do I contribute?

Fork, write tests, add your code and send a pull request. If you modify existing files, please adhere to the coding standard surrounding your code. If you wish to report an issue, please use the GitHub issue tracker. I can also be contacted by mail (visible on my GitHub user page).

Development dependencies are specified in the gem specification, and can be installed using rubygems.

gem install em-throttled_queue --development

There’s also a Gemfile in the repository, allowing you to install dependencies via bundler.

bundleinstall

Why don’t you support 1.8.7?

There currently is no reason for me to do so. If you believe there is, file an issue.