   end
 
   test "aggregates rows with escape sequences that are starting with a linebreak" do
-    stream = Stream.map(["a,be,\"", "c,d\"", "g,h,i", "i,j,k", "k,l,m"], &(&1))
+    stream = Stream.map(["a,be,\"", "c,d\"", "g,h,i"], &(&1))
     aggregated = stream |> LineAggregator.aggregate |> Enum.into([])
     assert aggregated == [
       "a,be,\"\r\nc,d\"",
-      "g,h,i",
-      "i,j,k",
-      "k,l,m"
+      "g,h,i"
     ]
   end
 

    ]
  end

  test "aggregates escaped, unterminated rows with multiple quotes" do
    stream = Stream.map(["a,\"\"\"be", "c,d", "e,f\"", "g,h"], &(&1))
    aggregated = stream |> LineAggregator.aggregate |> Enum.into([])
    assert aggregated == [

    ]
  end

  test "aggregates unterminated escape sequences over rows with different separators" do
    stream = Stream.map(["a\t\"be", "c\td", "e\tf\"", "g\th"], &(&1))
    aggregated = stream |> LineAggregator.aggregate(separator: ?\t) |> Enum.into([])
    assert aggregated == [
