Super ... you guys are awesome ... more I am learning, it is becoming more and more interesting.
I used recover, It worked well. Thanks a lot. On Thursday, March 10, 2016 at 4:52:30 PM UTC-6, √ wrote: > > > http://doc.akka.io/api/akka/2.4.2/?_ga=1.176202021.1085570125.1455222020#akka.stream.scaladsl.FlowOps > > -- > Cheers, > √ > On Mar 10, 2016 11:43 PM, "Arun Sethia" <sethi...@gmail.com <javascript:>> > wrote: > >> Thanks. >> >> please can you provide the link where I can see how to deal with such >> errors. >> >> On Thursday, March 10, 2016 at 4:22:35 PM UTC-6, √ wrote: >>> >>> For each only deals with elements, not errors. >>> Please consult the documentation for combinators that let you observe >>> and manipulate errors. >>> >>> -- >>> Cheers, >>> √ >>> On Mar 10, 2016 11:04 PM, "Arun Sethia" <sethi...@gmail.com> wrote: >>> >>>> httpSourceGraph1 is httpSourceGraph , but still same issue >>>> >>>> >>>> val response= httpSourceGraph.via(httpConnFlow()).runForeach(println) >>>> >>>> >>>> we can test same with any external internet URL also, the result remain >>>> same. >>>> >>>> >>>> On Thursday, March 10, 2016 at 3:55:22 PM UTC-6, Arun Sethia wrote: >>>>> >>>>> Hi, >>>>> >>>>> I am trying to connect http client to a http service exposed by >>>>> server, the source should send request every 1 second for that I have >>>>> crated following partial graphs: >>>>> >>>>> >>>>> def httpSourceGraph() = { >>>>> Source.fromGraph(GraphDSL.create() { implicit builder => >>>>> val sourceOutLet = builder.add(Source.tick(FiniteDuration(0, >>>>> TimeUnit.SECONDS), FiniteDuration(1, >>>>> TimeUnit.SECONDS), >>>>> HttpRequest(uri ="/test", method = HttpMethods.GET))).out >>>>> // expose outlet >>>>> SourceShape(sourceOutLet) >>>>> }) >>>>> } >>>>> >>>>> >>>>> def httpConnFlow() = { >>>>> Flow.fromGraph(GraphDSL.create() { implicit builder => >>>>> >>>>> val httpSourceFlow = builder.add(Http(system).outgoingConnection(host >>>>> = "localhost", port = 8080)) >>>>> >>>>> FlowShape(httpSourceFlow.in, httpSourceFlow.out) >>>>> }) >>>>> } >>>>> >>>>> >>>>> the graph is composed as >>>>> >>>>> >>>>> val response= httpSourceGraph1.via(httpConnFlow()).runForeach(println) >>>>> >>>>> >>>>> if the http server (localhost:8080/test) is up and running, everything >>>>> works fine, every 1 second I can see the response coming back from the >>>>> server. I am not able to any response in case of either server is down >>>>> or it goes down later. >>>>> >>>>> >>>>> *I think it should give me following error:* >>>>> >>>>> >>>>> akka.stream.StreamTcpException: Tcp command >>>>> [Connect(localhost/127.0.0.1:8080,None,List(),Some(10 seconds),true)] >>>>> failed >>>>> >>>>> >>>>> Thanks for the help. >>>>> >>>>> -Arun >>>>> >>>>> >>>>> >>>>> >>>>> -- >>>> >>>>>>>>>> Read the docs: http://akka.io/docs/ >>>> >>>>>>>>>> Check the FAQ: >>>> http://doc.akka.io/docs/akka/current/additional/faq.html >>>> >>>>>>>>>> Search the archives: >>>> https://groups.google.com/group/akka-user >>>> --- >>>> You received this message because you are subscribed to the Google >>>> Groups "Akka User List" group. >>>> To unsubscribe from this group and stop receiving emails from it, send >>>> an email to akka-user+...@googlegroups.com. >>>> To post to this group, send email to akka...@googlegroups.com. >>>> Visit this group at https://groups.google.com/group/akka-user. >>>> For more options, visit https://groups.google.com/d/optout. >>>> >>> -- >> >>>>>>>>>> Read the docs: http://akka.io/docs/ >> >>>>>>>>>> Check the FAQ: >> http://doc.akka.io/docs/akka/current/additional/faq.html >> >>>>>>>>>> Search the archives: https://groups.google.com/group/akka-user >> --- >> You received this message because you are subscribed to the Google Groups >> "Akka User List" group. >> To unsubscribe from this group and stop receiving emails from it, send an >> email to akka-user+...@googlegroups.com <javascript:>. >> To post to this group, send email to akka...@googlegroups.com >> <javascript:>. >> Visit this group at https://groups.google.com/group/akka-user. >> For more options, visit https://groups.google.com/d/optout. >> > -- >>>>>>>>>> Read the docs: http://akka.io/docs/ >>>>>>>>>> Check the FAQ: >>>>>>>>>> http://doc.akka.io/docs/akka/current/additional/faq.html >>>>>>>>>> Search the archives: https://groups.google.com/group/akka-user --- You received this message because you are subscribed to the Google Groups "Akka User List" group. To unsubscribe from this group and stop receiving emails from it, send an email to akka-user+unsubscr...@googlegroups.com. To post to this group, send email to akka-user@googlegroups.com. Visit this group at https://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.
