Class: Dataflow::Actor

Inherits:

Thread

• Object
• Thread
• Dataflow::Actor

Defined in:

lib/actor.rb

Instance Method Summary

• #initialize(&block) ⇒ Actor constructor

  A new instance of Actor.

• #send(message) ⇒ Object

Constructor Details

#initialize(&block) ⇒ Actor

Returns a new instance of Actor.

# File 'lib/actor.rb', line 3

def initialize(&block)
  @stream = Variable.new
  @port = Port.new(@stream)
  # Run this block in a new thread
  super { instance_eval &block }
end

Instance Method Details

#send(message) ⇒ Object

# File 'lib/actor.rb', line 10

def send message
  @port.send message
end