Refactor

electric-sql · Sep 26, 2024 · 85ba982 · 85ba982
1 parent b8deb91
commit 85ba982
Showing 1 changed file with 1 addition and 5 deletions.
diff --git a/packages/sync-service/lib/electric/shapes/consumer.ex b/packages/sync-service/lib/electric/shapes/consumer.ex
@@ -72,11 +72,7 @@ defmodule Electric.Shapes.Consumer do
   defp selector(%Transaction{changes: changes}, shape) do
     changes
     |> Stream.flat_map(&Shape.convert_change(shape, &1))
-    |> Enum.take(1)
-    |> case do
-      [] -> false
-      [_] -> true
-    end
+    |> Enum.any?()
   end
 
   defp selector(_, _), do: false