bjonnh
03/11/2019, 4:07 AMproduce<String>(<http://Dispatchers.IO|Dispatchers.IO>, capacity = 1024) {
input.forEachLine { async { send(it) } }
}.map(context) {
val tokenized = tokenizerFactory.create(pp.preProcess(it)).tokens.joinToString(" ")
tokenized + "\n"
}.map(<http://Dispatchers.IO|Dispatchers.IO>) {
output.appendText(it)
}