[akka-user] new project - akka streams/http - is using the current spray release with akka streams and migrating later too painful?

Hi, I need to start a new project in a couple of months (and hopefully have a first working prototype in 2-3 months more). I am a rxscala/java user, and am following the reactive streams/akka streams projects with huge interest. For the api layer, akka-http is too immature to be used right now

[akka-user] Re: Akka Stream: How to dynamically group elements?

Hi. thanks for the quick reply, that's exactly what I was looking for. ciao, elm -- 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

Re: [akka-user] tcp client server recommendations

On Sun, Feb 1, 2015 at 9:05 PM, Jeremy Stone jeremymichaelst...@gmail.com wrote: Would something like the following in the server handler do it for you?... def silentSource = ??? // Source that emits nothing but does never completes def handleDataFromClient: ByteString = Unit = ???

Re: [akka-user] Re: Implementing at-least-once ingestion pipeline with Akka streams

Hi Evan, As we progress we make more and more things possible, we will keep this use-case in mind. -Endre On Sat, Jan 31, 2015 at 2:52 AM, Evan Chan vel...@gmail.com wrote: Thanks Bjorn. On Fri, Jan 30, 2015 at 2:33 AM, Björn Antonsson bjorn.antons...@typesafe.com wrote: Hi Evan, I

[akka-user] Re: Send message from netty code to actor system

You can try Xitrum web framework (scroll down to see the Akka actor example): http://xitrum-framework.github.io/ On Tuesday, January 27, 2015 at 6:29:43 PM UTC+9, Jabbar Azam wrote: Hello, How do I send a message from java non actor based code into an actor system? The code will be

Re: [akka-user] Relation between Number of cores number of actors

Hi Samya, On Sun, Feb 1, 2015 at 9:43 AM, Samya Maiti samya.maiti2...@gmail.com wrote: Hi Team, I have a small akka application which works fine, processes some thousand messages per second. But I am curious to Know : 1. How is number of cores of a system related to number of actors?

Re: [akka-user] tcp client server recommendations

Hey that's pretty nifty! In the meantime, Jeremy's silent actor publisher is working well. Thanks, Peter On Monday, February 2, 2015 at 1:30:57 AM UTC-8, drewhk wrote: On Sun, Feb 1, 2015 at 9:05 PM, Jeremy Stone jeremymic...@gmail.com javascript: wrote: Would something like the

[akka-user] Using different names for application.conf

My application consists out of multiple services (daemons) which unfortunately have to share the location for configuration files. I would prefer to avoid maintaining single application.conf which is shared by all services due to logistical reasons. I also cannot package individual

Re: [akka-user] Akka Stream: How to dynamically group elements?

Hi Elmar, On Mon, Feb 2, 2015 at 6:40 PM, Elmar Weber goo...@elmarweber.org wrote: I am looking to batch elements in a flow in a non-standard way and sending them off. A typical flow for this based on a static count would look like this: Source[Element] .grouped(batchSize)

[akka-user] Akka Stream: How to dynamically group elements?

I am looking to batch elements in a flow in a non-standard way and sending them off. A typical flow for this based on a static count would look like this: Source[Element] .grouped(batchSize) .map(doRest(elements) .Sink[LogResultsSomewhere] Now, instead of a batchSize I want a different

Re: [akka-user] Akka Stream: How to dynamically group elements?

On Mon, Feb 2, 2015 at 6:49 PM, Akka Team akka.offic...@gmail.com wrote: Hi Elmar, On Mon, Feb 2, 2015 at 6:40 PM, Elmar Weber goo...@elmarweber.org wrote: I am looking to batch elements in a flow in a non-standard way and sending them off. A typical flow for this based on a static count