Contents

module Jugglite
  class DeferrableBody
    include EventMachine::Deferrable

    def initialize
      @queue = EM::Queue.new
    end

    def write(body)
      @queue.push(body)
    end

    def each &blk
      @body_callback = blk
      processor = proc { |item|
        @body_callback.call(item)
        @queue.pop(&processor)
      }
      @queue.pop(&processor)
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
jugglite-0.0.1.alpha	lib/jugglite/deferrable_body.rb