我正在制作可发送/接收异步消息的基本Elixir服务器/客户端模块。该模块看起来像下面。 defmodule Bitcoin.WorkerOne do
use GenServer
def start_link(opts) do
IO.puts " - Worker 1 started - "
GenServer.start_link(__MODULE__,:ok, opt
如果我GenStage的handle_demand/2方法是这样的： def handle_demand(demand, _state) when demand > 0 do
case Queue.dequeue do
nil ->
Logger.debug("Queue empty.")
{:noreply, [], []}
{job, up
我正在通过unit testing the handle_{call,cast,info} callbacks测试GenServer。我的一个文档测试 S的如下： @doc """
Call the GenServer to retrieve the initial workout
## Examples
我有这样一个天真的缓存GenServer /客户端执行使用ETS： defmodule Cache do
use GenServer
def start_link() do
GenServer.start_link(__MODULE__, [])
end
def fetch(key, def_value) do
case get(
我有一个表模块。当它作为gen_server启动时，它会从Clock模块创建2个服务器 - 一个用于X播放器，另一个用于O播放器。 10秒后，时钟会超时，该代码被称为： updateTick(Delta, {{Time, ticking, _}, Host}) ->
Now = Time - Delta,
case Now of
Now when Now > 0 ->