Hi,
There is a flatMap, it is just not called that. There is a flatten() method
that takes a strategy, currently the only one being concat:
flatten(FlattenStrategy.concat). The reason for that we don't provide a
method called flatMap is to avoid it being overused in for comprehensions.
In the land
This appears to me to be a problem with rates and cycles within the
HttpClient.transportToConnectionClientFlow.
Augmenting the flow with a buffer as described in
http://doc.akka.io/docs/akka-stream-and-http-experimental/1.0-M3/scala/stream-graphs.html
seems to get us much farther. Here's the
I see Scala pickling has a stable release
http://notes.implicit.ly/post/110275857699/pickling-0-10-0
If anyone has any updates on its viability for event versioning, please
post.
On Thu, Oct 23, 2014 at 1:16 PM, Christian Douven
wrote:
> We are using MessagePack as our binary serialization for
Hi *,
I am currently playing around with akka-http and so far I like it very
much. I am trying to rebuild an existing API and to do so I need to match
on URIs where there can be a variable number of segment between constant
parts.
Example:
/api/[...]/doSomething
In the above example URI, the
Hi Jeffrey,
Akka is built in Scala but offers Java APIs, so the "Scala downloads"
should be just fine.
However, if you are getting started I'd recommend the Activator download as
you can get started with the Akka Java tutorials.
On Sun, Feb 8, 2015 at 9:32 PM, Jeffrey Kelly wrote:
> I feel pre
I feel pretty stupid for asking this, but if I wanted to experiment with
Akka for Java, where would I find it? For all the Java/Scala parallel
documentation, the downloads section of the site only appears to provide
Scala options (along with an entire ecosystem that I'm not interested in).
I wa
Hello,
I haven't fully digested the documentation yet, so please forgive me if
this question is ill-posed. I have a basic many producers many consumers
problem, where producers and consumers may exist on the same node or may
not. Additionally producers may produce a number of tasks simultaneou
Hello again,
My idea right now is to specify buffer size explicitly and return
Future[Try[Unit]] that indicates result of enqueuing into buffered source.
I am not sure that there is right way, but I need to connect some non
stream based system with akka streams. Any thoughts?
Unfortunately, I
Cool!!!
I decide to write my own heavy PromiseActor and swift to PromiseActorRef
when it's been fixed!
Thanks,
IL
On Sunday, February 8, 2015 at 3:53:44 PM UTC+8, rkuhn wrote:
>
> Incidentally there is an open PR for fixing this:
> https://github.com/akka/akka/pull/16690 This will be sorted ou
