Packages
eventstore
0.5.2
1.4.8
1.4.7
1.4.6
1.4.4
1.4.3
1.4.2
1.4.1
1.4.0
1.3.2
1.3.1
1.3.0
1.2.3
1.2.2
1.2.1
1.2.0
1.1.0
1.0.3
1.0.2
1.0.1
1.0.0
1.0.0-rc.0
0.17.0
0.16.2
0.16.1
0.16.0
0.15.1
0.15.0
0.14.0
0.14.0-rc.0
0.13.2
0.13.1
0.13.0
0.12.1
0.12.0
0.11.0
0.11.0-rc.0
0.10.1
0.10.0
0.9.0
0.8.1
0.8.0
0.7.4
0.7.3
0.7.2
0.7.1
0.7.0
0.6.2
0.6.1
0.6.0
0.5.2
0.5.1
0.5.0
0.4.3
0.4.2
0.4.1
0.4.0
0.3.0
0.2.1
0.2.0
0.1.0
0.0.5
0.0.4
0.0.3
0.0.2
0.0.1
Event store using PostgreSQL for persistence.
Current section
65 Versions
Jump to
Current section
65 Versions
Compare versions
3
files changed
+6
additions
-7
deletions
| @@ -54,4 +54,4 @@ | |
| 54 54 | {<<"name">>,<<"postgrex">>}, |
| 55 55 | {<<"optional">>,false}, |
| 56 56 | {<<"requirement">>,<<"~> 0.12">>}]]}. |
| 57 | - {<<"version">>,<<"0.5.1">>}. |
| 57 | + {<<"version">>,<<"0.5.2">>}. |
| @@ -81,11 +81,10 @@ defmodule EventStore.Subscriptions do | |
| 81 81 | def handle_info({:DOWN, _ref, :process, pid, reason}, %Subscriptions{subscription_pids: subscription_pids} = subscriptions) do |
| 82 82 | _ = Logger.info(fn -> "subscription down due to: #{inspect reason}" end) |
| 83 83 | |
| 84 | - {stream_uuid, subscription_name} = Map.get(subscription_pids, pid) |
| 85 | - |
| 86 | - subscriptions = |
| 87 | - subscriptions |
| 88 | - |> remove_subscription(stream_uuid, subscription_name, pid) |
| 84 | + subscriptions = case Map.get(subscription_pids, pid) do |
| 85 | + nil -> subscriptions |
| 86 | + {stream_uuid, subscription_name} -> remove_subscription(subscriptions, stream_uuid, subscription_name, pid) |
| 87 | + end |
| 89 88 | |
| 90 89 | {:noreply, subscriptions} |
| 91 90 | end |
| @@ -4,7 +4,7 @@ defmodule EventStore.Mixfile do | |
| 4 4 | def project do |
| 5 5 | [ |
| 6 6 | app: :eventstore, |
| 7 | - version: "0.5.1", |
| 7 | + version: "0.5.2", |
| 8 8 | elixir: "~> 1.3", |
| 9 9 | elixirc_paths: elixirc_paths(Mix.env), |
| 10 10 | description: description, |