Skip to content

Commit 167fe48

Browse files
committed
Add pokémon clauses for unknown info messages
This is meant to protect against CaughtUp/FellBehind notifications introduced in <kurrent-io/KurrentDB@80d6546#diff-3f4777412535c46201e919412884d13ba6036db276eefe40ba84b8089b0c58f4> but it should be safe to ignore any other unknown info notifications as well.
1 parent 023682e commit 167fe48

File tree

2 files changed

+11
-0
lines changed

2 files changed

+11
-0
lines changed

lib/volley/in_order_subscription.ex

+4
Original file line numberDiff line numberDiff line change
@@ -458,6 +458,10 @@ defmodule Volley.InOrderSubscription do
458458
{:stop, reason, state}
459459
end
460460

461+
def handle_info(_, state) do
462+
{:noreply, [], state}
463+
end
464+
461465
# coveralls-ignore-stop
462466

463467
defp read_stream(state, demand) do

lib/volley/persistent_subscription.ex

+7
Original file line numberDiff line numberDiff line change
@@ -163,6 +163,13 @@ defmodule Volley.PersistentSubscription do
163163
{:noreply, [map_event(event, state)], state}
164164
end
165165

166+
# coveralls-ignore-start
167+
def handle_info(_, state) do
168+
{:noreply, [], state}
169+
end
170+
171+
# coveralls-ignore-stop
172+
166173
@impl GenStage
167174
def handle_demand(_demand, state) do
168175
{:noreply, [], state}

0 commit comments

Comments
 (0)