Невозможно использовать значение, возвращаемое агентом в цикле в эликсире

Question

Итак, у меня есть программа elixir, которая запускается в цикле и выполняет определенные операции. Я объявил агента для создания одного экземпляра соединения zookeeper, а затем использовать его в цикле. Вот мой код:

mix.exs

def application do
[ 
  applications: [:logger, :zookeeper],
  mod: {ServiceMonitor, []}
]

end    

defp deps do
[
  {:zookeeper, github: "vishnevskiy/zookeeper-elixir"}
]
end

service_monitor.ex

defmodule ServiceMonitor do
  def start(_type, _args) do
    {:ok, zk_agent} = Agent.start_link(fn -> ServiceMonitor.Registry.get_zk end)
    ServiceMonitor.Registry.start_process(zk_agent)
   end
end 

service_monitor / registry.ex

defmodule ServiceMonitor.Registry do
  alias Zookeeper.Client, as: ZK
  def start_process(zk) do

    pid = spawn_link(fn ->
        {:ok, data} = ZK.get_children(zk, "/test")
        IO.inspect(data)
    end)

    start_process(zk)

  end

  def get_zk do
    {:ok, zk} = ZK.start("localhost:2181")
    zk
  end
end

Теперь, если я печатаю pid zk, я всегда получаю одно и то же, что означает, что всегда возвращается один и тот же экземпляр zk. Но я получаю следующую ошибку:-

12:44:39.647 [error] GenServer #PID<0.165.0> terminating
** (stop) bad call: #Operation performed by zk
(elixir) lib/gen_server.ex:420: Agent.Server."handle_call (overridable 1)"/3
(stdlib) gen_server.erl:629: :gen_server.try_handle_call/4
(stdlib) gen_server.erl:661: :gen_server.handle_msg/5
(stdlib) proc_lib.erl:240: :proc_lib.init_p_do_apply/3
Last message: #
State: {:ok, #PID<0.166.0>} 

Кроме того, если я всегда инициализирую цикл zk in вместо ссылок из агента, мой код работает нормально.

PS:- Чтобы воспроизвести его, вам нужно иметь настройку zookeeper

Answer 1

Кажется, что я неправильно выполнял цикл для порожденного процесса. Решение Догберта о том, как получить значение, возвращаемое агентом в цикле, действительно сработало. Теперь я запускаю цикл для порожденного процесса следующим образом:

def start_process(zk_agent) do
    spawn(ServiceMonitor.Registry, :start,[zk_agent])
    :timer.sleep(@sleep_time)
    start_process(zk_agent)
end

def start_process(zk_agent) do
    zk = Agent.get(zk_agent, &(&1))
    #Other logics
end