Packages
extreme
0.10.1
1.1.4
1.1.3
1.1.2
1.1.1
1.1.1-rc01
1.1.0
1.1.0-rc9
1.1.0-rc8
1.1.0-rc7
1.1.0-rc6
1.1.0-rc5
1.1.0-rc4
1.1.0-rc3
1.1.0-rc2
1.1.0-rc1
1.0.7
1.0.6
1.0.5
1.0.4
1.0.3
1.0.2
1.0.1
1.0.0
0.13.4
0.13.3
0.13.2
0.13.1
0.13.0
0.12.1
0.12.0
0.11.0
0.10.4
0.10.3
0.10.2
0.10.1
0.10.0
0.9.2
0.9.1
0.9.0
0.8.1
0.8.0
0.7.1
0.7.0
0.6.2
0.6.1
0.6.0
0.5.5
0.5.4
0.5.3
0.5.2
0.5.1
0.5.0
0.4.3
0.4.2
0.4.1
Elixir TCP client for EventStore.
Current section
Files
Jump to
Current section
Files
lib/subscriptions_supervisor.ex
defmodule Extreme.SubscriptionsSupervisor do
use Supervisor
def start_link(connection, opts \\ []) do
Supervisor.start_link(__MODULE__, connection, opts)
end
def start_subscription(supervisor, subscriber, read_params) do
Supervisor.start_child(supervisor, [subscriber, read_params])
end
def start_subscription(supervisor, subscriber, stream, resolve_link_tos) do
Supervisor.start_child(supervisor, [subscriber, stream, resolve_link_tos])
end
def init(connection) do
children = [
worker(Extreme.Subscription, [connection], restart: :temporary),
]
supervise(children, strategy: :simple_one_for_one)
end
end