Akka Streams: добавление символов в начале и конце источника

Question

У меня есть источник объектов json, хранящийся в виде строк, которые я хотел бы представить в виде массива JSON.

Я делаю это:

source.intersperse(",\n").concat(Source.single("]").prepend(Source.single("[")))

Не похожечтобы работать, я никогда не вижу символы [ и ] в выходных данных.

Кроме того, как я могу сказать, как я могу сказать Akka Streams, что конец потока достигнут (я знаю сообщение окончания), так что это может добавить окончание символа? (Я могу знать, что это закончило чтение определенного сообщения в Кафке).

Спасибо

Answer 1

Это работает:

source.takeWhile(_.value != "EOF").intersperse("[", ",\n","]")

Примечание: конечно, вам нужно иметь строку EOF в конце вашего источника, чтобы этот пример работал.