Merge pull request #98 from iamvery/process-koans

Rearrange, rm, and add process examples

lib/koans/10_processes.ex

@@ -11,13 +11,17 @@ defmodule Processes do
     assert information[:status] == ___
   end
 
+  koan "Processes are referenced by their process ID (pid)" do
+    assert is_pid(self) == ___
+  end
+
   koan "New processes are spawned functions" do
     pid = spawn(fn -> nil end)
 
     assert Process.alive?(pid) == ___
   end
 
-  koan "You can send messages to processes" do
+  koan "Processes can send and receive messages" do
     send self, "hola!"
 
     receive do
@@ -25,16 +29,69 @@ defmodule Processes do
     end
   end
 
+  koan "Received messages are queued, first in first out" do
+    send self, "hola!"
+    send self, "como se llama?"
+
+    assert_receive ___
+    assert_receive ___
+  end
+
   koan "A common pattern is to include the sender in the message, so that it can reply" do
-    pid = spawn(fn -> receive do
+    greeter = fn ->
-                         {:hello, sender} -> send sender, :how_are_you?
+      receive do
-                      end
+        {:hello, sender} -> send sender, :how_are_you?
-                 end)
+      end
+    end
+
+    pid = spawn(greeter)
 
     send pid, {:hello, self}
     assert_receive ___
   end
 
+  def yelling_echo_loop do
+    receive do
+      {caller, value} ->
+        send caller, String.upcase(value)
+        yelling_echo_loop
+    end
+  end
+
+  koan "Use tail recursion to receive multiple messages" do
+    pid = spawn_link(&yelling_echo_loop/0)
+
+    send pid, {self, "o"}
+    assert_receive ___
+
+    send pid, {self, "hai"}
+    assert_receive ___
+  end
+
+  def state(value) do
+    receive do
+      {caller, :get} ->
+        send caller, value
+        state(value)
+      {caller, :set, new_value} ->
+        state(new_value)
+    end
+  end
+
+  koan "Processes can be used to hold state" do
+    initial_state = "foo"
+    pid = spawn(fn ->
+      state(initial_state)
+    end)
+
+    send pid, {self, :get}
+    assert_receive ___
+
+    send pid, {self, :set, "bar"}
+    send pid, {self, :get}
+    assert_receive ___
+  end
+
   koan "Waiting for a message can get boring" do
     parent = self
     spawn(fn -> receive do
@@ -46,20 +103,6 @@ defmodule Processes do
     assert_receive ___
   end
 
-  koan "Killing a process will terminate it" do
-    pid = spawn(fn -> Process.exit(self, :kill) end)
-    :timer.sleep(500)
-    assert Process.alive?(pid) == ___
-  end
-
-  koan "You can also terminate processes other than yourself" do
-    pid = spawn(fn -> receive do end end)
-
-    assert Process.alive?(pid) == ___
-    Process.exit(pid, :kill)
-    assert Process.alive?(pid) == ___
-  end
-
   koan "Trapping will allow you to react to someone terminating the process" do
     parent = self
     pid = spawn(fn ->
@@ -79,21 +122,7 @@ defmodule Processes do
     assert_receive ___
   end
 
-  koan "Trying to quit normally has no effect" do
+  koan "Parent processes can trap exits for children they are linked to" do
-    pid = spawn(fn -> receive do end end)
-    Process.exit(pid, :normal)
-
-    assert Process.alive?(pid) == ___
-  end
-
-  koan "Exiting normally yourself on the other hand DOES terminate you" do
-    pid = spawn(fn -> Process.exit(self, :normal) end)
-    :timer.sleep(100)
-
-    assert Process.alive?(pid) == ___
-  end
-
-  koan "Parent processes can be informed about exiting children, if they trap and link" do
     Process.flag(:trap_exit, true)
     spawn_link(fn -> Process.exit(self, :normal) end)
 

test/koans/processes_koans_test.exs

@@ -7,17 +7,17 @@ defmodule ProcessesTests do
       true,
       :running,
       true,
-      "hola!",
-      :how_are_you?,
-      {:waited_too_long, "I am impatient"},
-      false,
-      {:multiple, [true, false]},
-      {:exited, :random_reason},
       true,
-      false,
+      "hola!",
+      {:multiple, ["hola!", "como se llama?"]},
+      :how_are_you?,
+      {:multiple, ["O", "HAI"]},
+      {:multiple, ["foo", "bar"]},
+      {:waited_too_long, "I am impatient"},
+      {:exited, :random_reason},
       :normal,
       :normal,
-      ]
+    ]
 
     test_all(Processes, answers)
   end