in jbang/pipe/to_csv.java [13:23]
public void configure() throws Exception {
// read from system:in
from("stream:in")
// aggregate all lines together using comma as separator
.aggregate(constant("true")).completionTimeout(100)
.aggregationStrategy(AggregationStrategies.string(separator))
// append new line to mark end of line
.setBody().simple("${body}\n")
// write to system:out
.to("stream:out");
}