Current section

Files

Jump to
workex lib server.ex
Raw

lib/server.ex

defmodule Workex.Server do
@moduledoc """
A gen_server based process which can be used to manipulate multiple workers and send
them messages. See readme for detailed description.
"""
use ExActor.Tolerant
def init(workex_args) do
initial_state(Workex.new(workex_args))
end
defcast push(worker_id, message), state: workex do
new_state(Workex.push(workex, worker_id, message))
end
definfo {:workex, msg}, state: workex do
workex
|> Workex.handle_message(msg)
|> new_state
end
definfo _, do: noreply
end