Skip to content
This repository

HTTPS clone URL

Subversion checkout URL

You can clone with HTTPS or Subversion.

Download ZIP

Provides queue driven by callbacks so suitable for asynchronous processing environments and its recurring variant for request distribution to more clients or emulating of server behaviour.

branch: master

Fetching latest commit…

Octocat-spinner-32-eaf2f5

Cannot retrieve the latest commit at this time

Octocat-spinner-32 lib
Octocat-spinner-32 .document
Octocat-spinner-32 .gitignore
Octocat-spinner-32 Gemfile
Octocat-spinner-32 Gemfile.lock
Octocat-spinner-32 LICENSE.txt
Octocat-spinner-32 README.md
Octocat-spinner-32 Rakefile
Octocat-spinner-32 VERSION
Octocat-spinner-32 evented-queue.gemspec
Octocat-spinner-32 test
README.md

Ruby Evented Queue

evented-queue simply wraps non-evented queue to an evented interface. It directly uses the Unified Queues gem which means, wide spectrum of queues can be converted to the evented queues. Advantage of the evented queue is, they can be recurring, so can serve as de-facto permanent provider of the events.

An example:

require "evented-queue"
require "depq"      # will serve as example here

queue = EventedQueue::new(Depq)
queue.push(:foo)

queue.pop do |item|
    item    # will contain :foo
end

queue.push(:bar)

queue.pop do |item|
    item    # will contain :bar
end 

And recurring queue example:

require "evented-queue/recurring"

queue = EventedQueue::Recurring::new(Array)
queue.push(:foo)

queue.pop do |item|     # :foo will be written out now
    p item
end

queue.push(:bar)        # :bar will be written out now
queue.push(:delta)      # :delta will be written out now

Contributing

  1. Fork it.
  2. Create a branch (git checkout -b 20101220-my-change).
  3. Commit your changes (git commit -am "Added something").
  4. Push to the branch (git push origin 20101220-my-change).
  5. Create an Issue with a link to your branch.
  6. Enjoy a refreshing Diet Coke and wait.

Copyright

Copyright © 2011 - 2012 Martin Kozák. See LICENSE.txt for further details.

Something went wrong with that request. Please try again.