Repository is archived
No commit activity in last 3 years
No release in over 3 years
A rate-limited Queue for EventMachine
2005
2006
2007
2008
2009
2010
2011
2012
2013
2014
2015
2016
2017
2018
2019
2020
2021
2022
 Dependencies

Development

>= 0
>= 0

Runtime

 Project Readme

Throttled Queue is a throttled queue

ThrottledQueue is just like an EM::Queue, but will pop items off itself at a pace specified by you.

NOTE: Version v1.0.0 and v1.0.1 has an unintentional flaw, and should not be used.

NOTE: I personally won’t be doing any development on this library, but I will accept pull requests. If you want take over maintenance of this library for further development, please do contact me.

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::run do
  # Create a queue that will pop off maximum of 2 items per second.
  queue = EM::ThrottledQueue.new(2)

  queue.push 1 # you can push one item at a time
  queue.push 2, 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

gem install em-throttled_queue

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.

bundle install

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.