     ]
   end
 
-  test "aggregates escaped, unterminated rows with multiple quotes" do
+  test "aggregates unterminated escape sequences over 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 "fails on open escape sequences to the end of the stream" do
    stream = Stream.map(["a,\"be\"\"", "c,d", "e,f\",\"super,cool\"", "g,h,i", "i,j,\"k", "k,l,m"], &(&1))
    assert_raise CorruptStreamError, fn ->
      stream |> LineAggregator.aggregate |> Stream.run
    end
  end

end

    ]
  end

  test "aggregates unterminated escape sequences where the sequence begins at the start of the row" do
    stream = Stream.map(["\"\"\"be", "c,d", "e,f\",g", "g,h"], &(&1))
    aggregated = stream |> LineAggregator.aggregate |> Enum.into([])
    assert aggregated == [
