Module: MessagePack::RPC::LoopUtil

Included in:
Client, SessionPool
Defined in:
lib/msgpack/rpc/loop.rb

Defined Under Namespace

Classes: TaskQueue, Timer

Instance Attribute Summary collapse

Instance Method Summary collapse

Instance Attribute Details

#loop ⇒ Object (readonly)

Returns the value of attribute loop.



26
27
28
 
# File 'lib/msgpack/rpc/loop.rb', line 26

def loop
  @loop
end

Instance Method Details

#run ⇒ Object 



72
73
74
 
# File 'lib/msgpack/rpc/loop.rb', line 72

def run
  @loop.run
end

#start_timer(interval, repeating, &block) ⇒ Object 



38
39
40
 
# File 'lib/msgpack/rpc/loop.rb', line 38

def start_timer(interval, repeating, &block)
  @loop.attach Timer.new(interval, repeating, &block)
end

#stop ⇒ Object 



76
77
78
79
80
81
82
 
# File 'lib/msgpack/rpc/loop.rb', line 76

def stop
  @queue.detach if @queue && @queue.attached?
  @loop.stop
  # attach dummy timer
  @loop.attach Cool.io::TimerWatcher.new(0, false)
  nil
end

#submit(task = nil, &block) ⇒ Object 



63
64
65
66
67
68
69
70
 
# File 'lib/msgpack/rpc/loop.rb', line 63

def submit(task = nil, &block)
  task ||= block
  unless @queue
    @queue = TaskQueue.new
    @loop.attach(@queue)
  end
  @queue.push(task)
end