Re: [akka-user] Split bytestring source into several sources

2016-02-23 Thread Kyrylo Stokoz
Hi Endre, Thank you for an answer, i found working for me solution. Which looks like this: I tweak jawn async json parse to be able to handle such json structure in streaming way, so i can convert Source[ByteString] into Source[(String, JValue)], where string is a name of json array. Now i can

Re: [akka-user] Split bytestring source into several sources

2016-02-22 Thread Akka Team
Hi, This is not an easy task, I am not sure how to do it with built-in combinators (you can do such custom stages but they are quite advanced and we have not yet openly documented all APIs that is needed for these kind of stages). But the largest issue will be that Source[A] and Source[B] will not

[akka-user] Split bytestring source into several sources

2016-02-10 Thread Kyrylo Stokoz
Hi, I have an http server that accept post request where http entity is chuncked and can be quite big, basically entity is a json of the following format: {code} { "shortlist" : [ { serialized objA } ], // up to 100items "verylonglist": [{serialized objB}], // up to ~5M } {code} I was t