Class: Dataflow::Actor

Inherits:

Thread

Object
Thread
Dataflow::Actor

show all

Defined in:: lib/vendor/dataflow/dataflow/actor.rb

Instance Method Summary collapse

#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/vendor/dataflow/dataflow/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`



10
11
12

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

def send message
  @port.send message
end