Skip to content

Commit

Permalink
Formatting
Browse files Browse the repository at this point in the history
  • Loading branch information
bryanjos committed Jun 13, 2024
1 parent 422bb04 commit 5c87c2b
Showing 1 changed file with 4 additions and 2 deletions.
6 changes: 4 additions & 2 deletions lib/absinthe/subscription/stage_supervisor.ex
Original file line number Diff line number Diff line change
Expand Up @@ -13,11 +13,13 @@ defmodule Absinthe.Subscription.StageSupervisor do
shards = Enum.to_list(0..(pool_size - 1))
buffer_size = 10_000

unique_producer_name = :"#{Absinthe.Subscription.LocalProducer}.#{:erlang.unique_integer([:monotonic])}"
unique_producer_name =
:"#{Absinthe.Subscription.LocalProducer}.#{:erlang.unique_integer([:monotonic])}"

children = [
{Absinthe.Subscription.LocalProducer, [pubsub, shards, buffer_size, unique_producer_name]},
{Absinthe.Subscription.LocalConsumerSupervisor, [min_demand, max_demand, unique_producer_name]}
{Absinthe.Subscription.LocalConsumerSupervisor,
[min_demand, max_demand, unique_producer_name]}
]

Supervisor.init(children, strategy: :one_for_one)
Expand Down

0 comments on commit 5c87c2b

Please sign in to comment.