Parent

Files

Class/Module Index [+]

Quicksearch

Concurrent::Channel::Buffer::Timer

Public Instance Methods

next() click to toggle source
# File lib/concurrent/channel/buffer/timer.rb, line 31
def next
  loop do
    tick, more = do_poll
    return tick, more if tick
    Thread.pass
  end
end
offer(item) click to toggle source
# File lib/concurrent/channel/buffer/timer.rb, line 16
def offer(item)
  false
end
poll() click to toggle source
# File lib/concurrent/channel/buffer/timer.rb, line 39
def poll
  tick, _ = do_poll
  tick = Concurrent::NULL unless tick
  tick
end
put(item) click to toggle source
# File lib/concurrent/channel/buffer/timer.rb, line 12
def put(item)
  false
end
take() click to toggle source
# File lib/concurrent/channel/buffer/timer.rb, line 20
def take
  loop do
    tick, _ = do_poll
    if tick
      return tick
    else
      Thread.pass
    end
  end
end

[Validate]

Generated with the Darkfish Rdoc Generator 2.