Skip to content

Commit

Permalink
Merge branch 'release/2.6.1'
Browse files Browse the repository at this point in the history
  • Loading branch information
zacksiri committed Nov 5, 2024
2 parents ee1d4b8 + 387651f commit e735225
Show file tree
Hide file tree
Showing 2 changed files with 7 additions and 8 deletions.
13 changes: 6 additions & 7 deletions lib/lexdee/observer.ex
Original file line number Diff line number Diff line change
Expand Up @@ -35,15 +35,14 @@ defmodule Lexdee.Observer do
GenServer.call(pid, :connect)
end

def connect(supervisor, pid) do
def connect(supervisor, pid) when is_pid(pid) do
node = which_node(pid)

task =
Task.Supervisor.async_nolink({supervisor, node}, fn ->
GenServer.call(pid, :connect)
end)

Task.yield(task)
{supervisor, node}
|> Task.Supervisor.async_nolink(fn ->
GenServer.call(pid, :connect)
end)
|> Task.await()
end

def start_link(options) do
Expand Down
2 changes: 1 addition & 1 deletion mix.exs
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,7 @@ defmodule Lexdee.MixProject do
def project do
[
app: :lexdee,
version: "2.6.0",
version: "2.6.1",
elixir: "~> 1.9",
elixirc_paths: elixirc_paths(Mix.env()),
start_permanent: Mix.env() == :prod,
Expand Down

0 comments on commit e735225

Please sign in to comment.