diff --git a/packages/sync-service/lib/electric/shapes/consumer.ex b/packages/sync-service/lib/electric/shapes/consumer.ex index bec109b526..7c96e6639d 100644 --- 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