csys: clarifications and improvements

lib/csys/csys.ex

@@ -15,16 +15,17 @@ defmodule Scopes.CSys do
     send(env, msg)
   end
 
-  def std_proc(msg, {state, syns, env}) do
+  def forward(msg, {_state, syns, _env}) do
-    case msg do
+    for s <- syns, do: s.(msg)
-      {:parent} ->
+  end
-        syn = synapse(self(), fn x -> x end)
-        new = Actor.create(neuron(&std_proc/2, {nil, [syn], env}))
-        # Actor.become(&std_proc/2, {state, syns, env})
-        send(env, {:created, new})
 
-      msg ->
+  def std_proc({:parent}, {_state, _syns, env}) do
-        echo(msg, {state, syns, env})
+    syn = synapse(self(), &Function.identity/1)
-    end
+    new = Actor.create(neuron(&std_proc/2, {nil, [syn], env}))
+    send(env, {:created, new})
+  end
+
+  def std_proc(msg, scope) do
+    if forward(msg, scope) === [], do: echo(msg, scope)
   end
 end

test/csys_test.exs

@@ -1,6 +1,7 @@
 defmodule Scopes.CSysTest do
   use ExUnit.Case, async: true
   @moduletag timeout: 5000
+
   alias Scopes.Core.Actor
   alias Scopes.CSys
 
@@ -10,13 +11,11 @@ defmodule Scopes.CSysTest do
       Actor.send(zero, "Hello Zero!")
       assert_receive "Hello Zero!"
       Actor.send(zero, {:parent})
-
+      assert_receive {:created, new}
-      receive do
+      Actor.send(new, "Hello New!")
-        {:created, new} -> Actor.send(new, "Hello New!")
-      end
-
       assert_receive "Hello New!"
-      :timer.sleep(50)
+      #assert_receive "Hello New!"
+      Process.sleep(50)
       # Actor.stop(zero)
       refute_received msg, "unhandled message(s): #{inspect(msg)}"
     end