From 5a9a4ded49b32322a702e9ae3a02d3e4238b41a0 Mon Sep 17 00:00:00 2001 From: kballou Date: Tue, 21 Oct 2014 18:08:30 -0600 Subject: Add `leave` to pool scheduler api --- lib/poolparty/scheduler.ex | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/lib/poolparty/scheduler.ex b/lib/poolparty/scheduler.ex index dc9e1b3..dc4d731 100644 --- a/lib/poolparty/scheduler.ex +++ b/lib/poolparty/scheduler.ex @@ -30,6 +30,11 @@ defmodule PoolParty.Scheduler do GenServer.cast(__MODULE__, {:ready, result, worker_pid}) end + def leave(worker_pid) do + Logger.debug("[#{__MODULE__}]: Worker leaving pool") + GenServer.cast(__MODULE__, {:leave, worker_pid}) + end + def process(func, args, from) do Logger.debug("[#{__MODULE__}]: Casting work request") GenServer.cast(__MODULE__, {:process, func, args, from}) -- cgit v1.2.1