class Celluloid::Internals::Receiver

Methods blocking on a call to receive

Attributes

timer[RW]

Public Class Methods

new(block) click to toggle source
# File lib/celluloid/internals/receivers.rb, line 48
def initialize(block)
  @block = block
  @task  = Task.current
  @timer = nil
end

Public Instance Methods

match(message) click to toggle source

Match a message with this receiver's block

# File lib/celluloid/internals/receivers.rb, line 55
def match(message)
  @block ? @block.call(message) : true
end
resume(message = nil) click to toggle source
# File lib/celluloid/internals/receivers.rb, line 59
def resume(message = nil)
  @task.resume message
end