MessagePack::RPC::LoopUtil

    # File lib/msgpack/rpc/loop.rb, line 72
72:         def run
73:                 @loop.run
74:         end

    # File lib/msgpack/rpc/loop.rb, line 38
38:         def start_timer(interval, repeating, &block)
39:                 @loop.attach Timer.new(interval, repeating, &block)
40:         end

    # File lib/msgpack/rpc/loop.rb, line 76
76:         def stop
77:                 @queue.detach if @queue && @queue.attached?
78:                 @loop.stop
79:                 # attach dummy timer
80:                 @loop.attach Rev::TimerWatcher.new(0, false)
81:                 nil
82:         end

    # File lib/msgpack/rpc/loop.rb, line 63
63:         def submit(task = nil, &block)
64:                 task ||= block
65:                 unless @queue
66:                         @queue = TaskQueue.new
67:                         @loop.attach(@queue)
68:                 end
69:                 @queue.push(task)
70:         end