Contents

module Sideband
  class Queue

    def initialize
      @queue = ::Queue.new
    end

    def kill
      @queue << nil
    end

    def push(work)
      return false if work.nil?
      @queue.push(work)
      true
    end
    alias_method :<<, :push

    def pop
      @queue.pop
    end

  end
end

Version data entries

5 entries across 5 versions & 1 rubygems

Version	Path
sideband-1.0.4	lib/sideband/queue.rb
sideband-1.0.3	lib/sideband/queue.rb
sideband-1.0.2	lib/sideband/queue.rb
sideband-1.0.1	lib/sideband/queue.rb
sideband-1.0.0	lib/sideband/queue.rb