Sha256: 9be6a43146983b95531007333446f00dabd9e4203892194713f5c266d810d6ce
Contents?: true
Size: 744 Bytes
Versions: 6
Compression:
Stored size: 744 Bytes
Contents
require "thread" module Bunny module Concurrent # Continuation queue implementation for MRI and Rubinius # # @private class ContinuationQueue def initialize(*args, &block) @q = ::Queue.new(*args) end def push(*args) @q.push(*args) end alias << push def pop @q.pop end def poll(timeout_in_ms = nil) if timeout_in_ms Bunny::Timeout.timeout(timeout_in_ms / 1000, Timeout::Error) do @q.pop end else @q.pop end end def clear @q.clear end def method_missing(selector, *args, &block) @q.__send__(selector, *args, &block) end end end end
Version data entries
6 entries across 6 versions & 1 rubygems