[akka-user] Parsing Akka Http Json Response

2017-09-19 Thread bordecorp
Hello, I'm new to the AKKA Http world. I have one of thing to accomodate in my code. Using *Routing*, I'm calling one of the API service to *complete *the response. Now, I want to parse this response before *complete *to send back to client (parsing and modification). Could someone help me,

[akka-user] Akka Http : Parsing Akka HttpResponse Entity Without Blocking

2017-10-05 Thread bordecorp
Hello, I'm very new to the Akka Http world. I'm calling an API which is returning me a JSON format string. So, I wanted to parse this whole HttpReponse entity using some JSON parser, verify if the JSON is in the format I'm expected and based on that I'll be replying back with some list of

Re: [akka-user] Uncaught error from thread - ContentType$WithMissingCharset

2017-10-11 Thread bordecorp
Hi Konrad, I think, the above VERSIONS resolved my issue. Thank you very much for the response. I tested my code and it is working now. (I'm working for a company so, hard to share the code.) Regards, Aditya Borde On Wednesday, October 11, 2017 at 12:00:40 AM UTC-4, Konrad Malawski wrote: > >

Re: [akka-user] Uncaught error from thread - ContentType$WithMissingCharset

2017-10-10 Thread bordecorp
Even I'm surprised, it is working fine for many requests if I fire it from Firefox and crashes with the above error after like 5-6 requests made. But , in Chrome it crashes with the same error after 1st request itself (showing me the output). Regards, Aditya Borde On Tuesday, October 10, 2017

Re: [akka-user] Uncaught error from thread - ContentType$WithMissingCharset

2017-10-10 Thread bordecorp
Thanks for quick reply, Konrad. Actually, I'm using - these json parsing dependencies in Gradle. compile group: 'org.json4s', name: 'json4s-native_2.12', version: '3.2.11' compile group: 'org.json4s', name: 'json4s-jackson_2.12', version: '3.5.0.RC1' compile group: 'de.heikoseeberger', name:

[akka-user] Uncaught error from thread - ContentType$WithMissingCharset

2017-10-10 Thread bordecorp
Hello, I'm receiving below exception in my application , *It is still showing me the result once though* and application crashes : This is my code : This failing at *complete :* Can someone help me on this : val resFuture = requests.map(x => (getFutureResp(req))) I'm making

Re: [akka-user] Uncaught error from thread - ContentType$WithMissingCharset

2017-10-10 Thread bordecorp
Ok. I'm currently using akkaHttp: "10.0.7", akka: "2.5.2". Is there an issue? Or What packages I should be using? On Tuesday, October 10, 2017 at 9:17:49 PM UTC-4, Konrad Malawski wrote: > > Actually depend on akka-http 10.0.10 and akka 2.5.6 ;-) > > — > Konrad `kto.so` Malawski > Akka

[akka-user] Re: HTTP Chunk Size Exceeds the Configured Limit

2017-11-10 Thread bordecorp
I saw, sometimes, I get into below issue - I use : where *emptyResult* of type : Map[String, List[(String, JValue)]] Note that, Maps *acc* and *curr *are getting bigger and bigger. It might have some GB of data while combining at last step. Sink.fold(Future{emptyResult}){ case (acc, curr) =>

[akka-user] Re: TCP idle-timeout encountered on connection

2017-11-16 Thread bordecorp
Full exception is : (akka.stream.scaladsl.TcpIdleTimeoutException: TCP idle-timeout encountered on connection to [*api.XYZ.com *:443], no bytes passed in the last 1 minute) On Thursday, November 16,

[akka-user] TCP idle-timeout encountered on connection

2017-11-16 Thread bordecorp
Hello, I'm facing this issue not always but few times (and I want to handle this in my code): *[ERROR] [11/16/2017 15:42:42.908] [myactor-threadpool-dispatcher-7] [TaskInvocation] TCP idle-timeout encountered on connection to [* *api.XYZ.com**:443], no bytes passed in the last 50 seconds

[akka-user] HTTP Chunk Size Exceeds the Configured Limit

2017-11-09 Thread bordecorp
Hello, I have API response coming as a JSON string where Server won't support chunked response. I'm using below sample code to parse the JSON using *Jackson parser*. type Result = Map[String, List[(String, JValue)]] private def apiResult(resp : HttpResponse): Future[Result] = {