diff --git a/lib/ch/row_binary.ex b/lib/ch/row_binary.ex index aa95a03..e0ec4e8 100644 --- a/lib/ch/row_binary.ex +++ b/lib/ch/row_binary.ex @@ -631,8 +631,14 @@ defmodule Ch.RowBinary do decode_rows(types, rest, _row = [], _rows = [], types) end - defp decode_types(<>, count, acc) do - decode_types(rest, count - 1, [type | acc]) + for {pattern, value} <- varints do + defp decode_types( + <>, + count, + acc + ) do + decode_types(rest, count - 1, [type | acc]) + end end @doc false