Parent

Rev::AsyncWatcher

Class Index [+]

Quicksearch

MessagePack::RPC::LoopUtil::TaskQueue

Public Class Methods

new() click to toggle source 
    # File lib/msgpack/rpc/loop.rb, line 43
43:                 def initialize
44:                         @queue = []
45:                         super
46:                 end

Public Instance Methods

on_signal() click to toggle source 
    # File lib/msgpack/rpc/loop.rb, line 53
53:                 def on_signal
54:                         while task = @queue.shift
55:                                 begin
56:                                         task.call
57:                                 rescue
58:                                 end
59:                         end
60:                 end
push(task) click to toggle source 
    # File lib/msgpack/rpc/loop.rb, line 48
48:                 def push(task)
49:                         @queue.push(task)
50:                         signal
51:                 end

Disabled; run with --debug to generate this.

[Validate]

Generated with the Darkfish Rdoc Generator 1.1.6.