Fix tests & add ConcurrentLimiter.delete/1

1 files changed, 9 insertions, 9 deletions

diff --git a/test/concurrent_limiter_test.exs b/test/concurrent_limiter_test.exs
index 090417e..83e9981 100644
--- a/test/concurrent_limiter_test.exs
+++ b/test/concurrent_limiter_test.exs
@@ -11,11 +11,11 @@ defmodule ConcurrentLimiterTest do
     ConcurrentLimiter.new(name, 2, 2)
     self = self()
 
-    spawn_link(fn -> sleepy(name, 500) end)
-    spawn_link(fn -> sleepy(name, 500) end)
-    spawn_link(fn -> sleepy(name, 500) end)
-    spawn_link(fn -> sleepy(name, 500) end)
-    spawn_link(fn -> sleepy(name, 500) end)
+    spawn_link(fn -> sleepy(self, name, 500) end)
+    spawn_link(fn -> sleepy(self, name, 500) end)
+    spawn_link(fn -> sleepy(self, name, 500) end)
+    spawn_link(fn -> sleepy(self, name, 500) end)
+    spawn_link(fn -> sleepy(self, name, 500) end)
     assert_receive :ok, 2000
     assert_receive :ok, 2000
     assert_receive {:error, :overload}, 2000
@@ -23,17 +23,17 @@ defmodule ConcurrentLimiterTest do
     assert_receive :ok, 2000
   end
 
-  defp sleepy(duration) do
+  defp sleepy(parent, name, duration) do
     result =
       ConcurrentLimiter.limit(name, fn ->
-        send(self, :ok)
-        Process.sleep(sleep)
+        send(parent, :ok)
+        Process.sleep(duration)
         :ok
       end)
 
     case result do
       :ok -> :ok
-      other -> send(self, other)
+      other -> send(parent, other)
     end
   end
 end