Как протестировать канал с помощью Phoenix.ChannelTest.close/2

У меня есть тест, который запускает сокетное соединение, подписывается и присоединяется к теме. Затем я отправляю сообщение в канал, который выполняет некоторую работу и сохраняет некоторые данные. Затем я использую ChannelTest.close/2 в сокете, который имитирует закрытие клиентом соединения. Затем я хотел бы изменить обработанные данные и создать другое соединение сокета, чтобы проверить некоторое поведение.

Моя проблема заключается в том, что ChannelTest.close/2 приводит к сбою моего теста и возвращает ** (EXIT from #PID<0.558.0>) shutdown: :closed. Как я могу предотвратить это?

Вот соответствующий код

defmodule PlexServer.EmpireChannelTest do  

  use PlexServer.ChannelCase

  alias PlexServer.EmpireChannel
  alias PlexServer.EmpireTemplate
  alias PlexServer.EmpireInstance

  setup do
    ...

    {:ok, _, socket} =
      socket("user_id", %{})
      |> subscribe_and_join(EmpireChannel,
        "empire:#{empire.id}",
        %{"guardian_token" => jwt})

    {:ok, socket: socket, empire: empire, jwt: jwt}
  end

  test "research infrastructure", %{socket: socket, empire: empire, jwt: jwt} do
    ...

    ref = push socket, "command", request
    assert_reply ref, :ok, _, 1000

    close(socket) #fails here

    ...
  end
end

defmodule PlexServer.UserSocket do
  use Phoenix.Socket
  use Guardian.Phoenix.Socket

  ## Channels
  # channel "rooms:*", PlexServer.RoomChannel
  channel "empire:*", PlexServer.EmpireChannel
  channel "user:*", PlexServer.UserChannel

  ## Transports
  transport :websocket, Phoenix.Transports.WebSocket

  def connect(_params,_) do
    :error
  end

  def id(_socket), do: nil
end


defmodule PlexServer.EmpireChannel do
  use PlexServer.Web, :channel
  use Guardian.Channel

  alias PlexServer.EmpireInstance
  alias PlexServer.EmpireServer

  ...

  def join("empire:" <> empire_id, %{claims: _claims, resource: user}, socket) do
    ...
    #Starts a process through a supervisor here
  end

  def join("empire:" <> _, _, _socket) do
    {:error, data_error(:auth, "not authorized, did you pass your jwt?")}
  end

  # Channels can be used in a request/response fashion
  # by sending replies to requests from the client
  def handle_in("ping", payload, socket) do
    {:reply, {:ok, payload}, socket}
  end

  def handle_in("show", _, socket) do    
    ...
  end

  def handle_in("command", request, socket) do
    ...
  end

  def handle_in("remove", _, socket) do
    ...
  end

  def handle_in("ship_templates", _, socket) do
    ...
  end
end

После ответа, связанного с комментариями, я добавил код:

Process.flag(:trap_exit, true)
monitor_ref = Process.monitor(socket.channel_pid)
close(socket)

Теперь я получаю другое сообщение об ошибке: ** (exit) exited in: GenServer.call(PlexServer.EmpireSupervisor, {:terminate_child, :empire4}, :infinity) ** (EXIT) no process