Re: [akka-user] How would you "connect" many independent graphs maintaining backpressure between them?

Hi! I use it in the example provided above. The problem is how to throttle other graphs that are not connected to throttled graph. On Friday, July 8, 2016 at 2:24:04 PM UTC+3, √ wrote: > > Considered Flow.throttle? > > On Fri, Jul 8, 2016 at 11:23 AM, Jack Daniels <rus.

[akka-user] How would you "connect" many independent graphs maintaining backpressure between them?

up vote down votefavorite Hey guys! I continue learning akka-streams and have new question . *Variables:* - Single http

[akka-user] Re: Loop in flow makes stream never end

I didn't know about existence of Partition fan-out since it's not in the documentation but I just saw in akka sources. Thus here is shorter version of "bad" flow val badFlow = Flow.fromGraph(GraphDSL.create() { implicit builder => import GraphDSL.Implicits._ val mergeEntrance =

[akka-user] Loop in flow makes stream never end

I have properly working graph that has flow with loop. Items go through as expected and everything is working. But unfortunately with bounded source graph never ends. Ever. How can I fix it ? Here is schema of my flow. [image: enter image description here]

Re: [akka-user] How do I get connected Inlet and Outlet ? Akka 2.4.6

> because: > > > http://doc.akka.io/docs/akka/2.4.6/scala/stream/stages-overview.html#throttle > and > throttle on > http://doc.akka.io/api/akka/2.4.6/#akka.stream.scaladsl.FlowOps > > -- > Konrad `ktoso` Malawski > Akka <http://akka.io> @ Lightbend <http://

[akka-user] How do I get connected Inlet and Outlet ? Akka 2.4.6

Hi guys! How do you throttle Flow in the latest Akka (2.4.6) ? I'd like to throttle Http client flow to limit number of requests to 3 requests per second. I found following example online but it's for old Akka and akka-streams ApI changed so much that I can't figure out how to rewrite it.

[akka-user] Re: Custom Supervision.Decider doesn't catch exception produced by ActorPublisher

I've made few additions to my question here http://stackoverflow.com/questions/32290285/custom-supervision-decider-doesnt-catch-exception-produced-by-actorpublisher -- Read the docs: http://akka.io/docs/ Check the FAQ: http://doc.akka.io/docs/akka/current/additional/faq.html

[akka-user] Custom Supervision.Decider doesn't catch exception produced by ActorPublisher

I'm building a library that is going to be used by 3rd-party. In one of my methods I return Stream[Item] that is asynchronously generated from result of paginated REST API call. I'm using my modification of BulkPullerAsync

[akka-user] How do I mix typed and untyped actors?

How do I mix typed and untyped actors ? As I understood I have to specify main actor when I create instance of ActorSystem like this val system: akka.typed.ActorSystem[Start] = akka.typed.ActorSystem(main, Props(mainBehaviour)) On the other hand I use akka-http which is initialized like

[akka-user] How can I extract Future[T] value in unmarshaller without blocking ?

I'm using akka-http 1.0.-RC4. How can I extract Future[T] value in unmarshaller without blocking ? Details are here http://stackoverflow.com/questions/31223016/why-akka-http-unmarshaler-returns-futuret-instead-of-t but in short here is what I want to do. I extended ScalaXmlSupport you