fix name determination in init callback

NFIBrokerage · Jun 4, 2021 · 1609eaf · 1609eaf
1 parent d58e8b2
commit 1609eaf
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 1 deletion.
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -6,6 +6,12 @@ The format is based on [Keep a
 Changelog](https://keepachangelog.com/en/1.0.0/), and this project adheres to
 [Semantic Versioning](https://semver.org/spec/v2.0.0.html).
 
+## 0.3.1 - 2021-06-04
+
+### Fixed
+
+- Fixed name determination for InOrder subscriptions
+
 ## 0.3.0 - 2021-06-04
 
 ### Added

diff --git a/lib/volley/in_order_subscription.ex b/lib/volley/in_order_subscription.ex
@@ -355,11 +355,12 @@ defmodule Volley.InOrderSubscription do
 
   @impl GenStage
   def init(opts) do
+    self = Keyword.get(opts, :name, self())
     {producer_opts, opts} = pop_producer_opts(opts)
 
     state =
       struct(__MODULE__, opts)
-      |> Map.put(:self, Keyword.get(opts, :name, self()))
+      |> Map.put(:self, self)
 
     {:producer, state, producer_opts}
   end