Re: [akka-user] [akka-stream] Junctions documentation and specs

2015-01-24 Thread Alexey Romanchuk
Hi Roland, I am not sure about pull request right now, but here an issue at least - https://github.com/akka/akka/issues/16716 пятница, 23 января 2015 г., 17:32:09 UTC+6 пользователь rkuhn написал: > > Hi Alexey, > > you are right on all counts; would you mind opening a ticket and/or a PR? > > Th

[akka-user] [akka-stream] Prebuilt Source with simple synchronous API

2015-01-24 Thread Alexey Romanchuk
Hey hakkers, I wonder why there is not such prebuilt Source that provides API to externally emit message by simple method call. I am talking about something like this: //building and starting flow val flow = ??? val source = ExternalSource[String] source.via(flow).to(BlackholeSink).run //using

[akka-user] distributed pub sub

2015-01-24 Thread Matteo Cusmai
Hi all, I have some questions about the distributed pub sub akka extension: 1. Does it work only in cluster environment? 2. Does it use gossip protocol for both subscriptions and publishing? 3. If so, does the system wait about 1 s to send messages to subscriptors? Thanks in advance, Matteo. --

Re: [akka-user] ClusterClient load balancing

2015-01-24 Thread Hengky Sucanda
Hi Martynas, Yes i think you are right, what i meant was about the control of the load balancing. The frontend node actually is part of the cluster as well, they just have different role. So i think it was clear that it would not be possible now if i want to change the load balancing mechanism.

[akka-user] Re: akka-http: (micro)service example

2015-01-24 Thread John Ferrolino
It would also be interesting if you also had something to share with testing particularly using akka-http and akka-stream test kits. Using your project as a template, I am trying to learn how to mock this : val telizeConnection = Http().outgoingConnection(config.getString(" services.telizeHost"

[akka-user] Akka-stream D3 activity visualizer

2015-01-24 Thread Tim Harper
Recently I gave a presentation at a local technology group about reactive-streams. In order to demonstrate back-pressure, I whipped up this project which both visualizes the graph of a stream and shows the activity as it runs. I built it on Spray (ironically) because I didn't know if a web-sock

Re: [akka-user] Akka-stream D3 activity visualizer

2015-01-24 Thread Konrad Malawski
This is really awesome, kudos Tim! Hoping to get to play around with it a bit more soon. Answering some in-lined questions you mention: * We do not yet have websockets in akka-http, but they are on the roadmap :-) * I think the lack of scala.js can be excused in this case, awesome execution! -- 

Re: [akka-user] Akka-stream D3 activity visualizer

2015-01-24 Thread Roland Kuhn
Wow that looks awesome, thanks for sharing! > 24 jan 2015 kl. 22:03 skrev Tim Harper : > > Recently I gave a presentation at a local technology group about > reactive-streams. In order to demonstrate back-pressure, I whipped up this > project which both visualizes the graph of a stream and show