streaming_csv.patch

Index: src/main/java/org/example/questionn/csv/CsvRenderer.java
IDEA additional info:
Subsystem: com.intellij.openapi.diff.impl.patch.CharsetEP
<+>UTF-8
===================================================================
--- src/main/java/org/example/questionn/csv/CsvRenderer.java	(revision 13e0a8fb07a40e89c39ea8f8176f4c2e6b590774)
+++ src/main/java/org/example/questionn/csv/CsvRenderer.java	(date 1592660439551)
@@ -3,11 +3,13 @@
 import ratpack.handling.Context;
 import ratpack.render.RendererSupport;
 
+import static ratpack.http.ResponseChunks.stringChunks;
+
 public class CsvRenderer extends RendererSupport<Csv>
 {
     @Override
     public void render(final Context ctx, final Csv csv)
     {
-        ctx.getResponse().send("text/csv", csv.toCsv());
+        ctx.render(stringChunks("text/csv", csv.toStreamingCsv()));
     }
 }
Index: src/main/java/org/example/questionn/csv/Csv.java
IDEA additional info:
Subsystem: com.intellij.openapi.diff.impl.patch.CharsetEP
<+>UTF-8
===================================================================
--- src/main/java/org/example/questionn/csv/Csv.java	(revision 13e0a8fb07a40e89c39ea8f8176f4c2e6b590774)
+++ src/main/java/org/example/questionn/csv/Csv.java	(date 1592660311228)
@@ -1,8 +1,14 @@
 package org.example.questionn.csv;
 
+import org.reactivestreams.Publisher;
+
+
+import ratpack.stream.Streams;
+
 public interface Csv
 {
     String[] fieldNames();
+
     Iterable<String[]> records();
 
     default String toCsv()
@@ -20,4 +26,10 @@
 
         return stringBuilder.toString();
     }
+
+    default Publisher<String> toStreamingCsv()
+    {
+        return Streams.publish(records())
+                .map(r -> String.join(",", r).concat("\n"));
+    }
 }