module Celluloid # High-priority internal system events class SystemEvent; end # Request to link with another actor class LinkingRequest < SystemEvent attr_reader :actor, :type def initialize(actor, type) @actor, @type = actor, type.to_sym raise ArgumentError, "type must be link or unlink" unless [:link, :unlink].include?(@type) end def process(links) case type when :link then links << actor when :unlink then links.delete actor end actor.mailbox << LinkingResponse.new(Actor.current, type) end end # Response to a link request class LinkingResponse attr_reader :actor, :type def initialize(actor, type) @actor, @type = actor, type.to_sym raise ArgumentError, "type must be link or unlink" unless [:link, :unlink].include?(@type) end end # An actor has exited for the given reason class ExitEvent < SystemEvent attr_reader :actor, :reason def initialize(actor, reason = nil) @actor, @reason = actor, reason end end # Name an actor at the time it's registered class NamingRequest < SystemEvent attr_reader :name def initialize(name) @name = name end end # Request for an actor to terminate class TerminationRequest < SystemEvent; end # Signal a condition class SignalConditionRequest < SystemEvent def initialize(task, value) @task, @value = task, value end def call @task.resume(@value) end end end