Class: Fiber

Inherits:

Object

show all

Class Method Summary collapse



56
57
58

# File 'lib/joffice/fiber_extensions.rb', line 56

def delete_subscription(node)
  subscriptions.delete(node)      
end



60
61
62

# File 'lib/joffice/fiber_extensions.rb', line 60

def delete_subscriptions
  current.subscriptions.clear    
end



64
65
66

# File 'lib/joffice/fiber_extensions.rb', line 64

def set_subscription(node, value)
  subscriptions[node]=value      
end

# File 'lib/joffice/fiber_extensions.rb', line 38

def sleep(timeout)
  f=current
  EventMachine::Timer.new(timeout) { f.resume }
  Fiber.yield
end

# File 'lib/joffice/fiber_extensions.rb', line 33

def sleep_to_next_tick
  current.run_on_next_tick(nil)
  Fiber.yield
end

Returns:



52
53
54

# File 'lib/joffice/fiber_extensions.rb', line 52

def subscribed?(node)
  subscriptions.has_key?(node)      
end



48
49
50

# File 'lib/joffice/fiber_extensions.rb', line 48

def subscription(node)
  subscriptions[node]      
end



44
45
46

# File 'lib/joffice/fiber_extensions.rb', line 44

def subscriptions
  current.subscriptions     
end

# File 'lib/joffice/fiber_extensions.rb', line 22

def run_on_next_tick(value)
  EM.next_tick do
    resume(value) if alive?
  end
end



28
29
30

# File 'lib/joffice/fiber_extensions.rb', line 28

def subscriptions
  @subscriptions||={}      
end