Мне было интересно, есть ли способ реализовать простой тип содержимого длины кадрирования в потоках Akka. У меня есть простой протокол для связи между двумя конечными точками, как показано ниже: (два символа новой строки отмечают начальный байт части тела)
Content-Type: application/json\n
Content-Length: 500\n
\n
-----------------------json-body-of-500-bytes-length---------------------------
Content-Type: application/json\n <-------Next Frame
Content-Length:.... so on
Все, что я мог бы повторно использовать из Akka Http, но его реализация синтаксического анализа сильно оптимизирована, другой вариант будет использовать Framing.delimiter, но он нуждается в модификации. Прежде чем я go опередил и потратил время на создание этой стадии графа, я хотел выяснить, есть ли что-то, что я могу просто составить и использовать?
Спасибо