I'm trying to better understand the new api. If I got it right, the new
type parameter of the various stream components represents the type of
what's materialized by that component when the stream is run
(materialized). E.g.: A Source(actorProducerProps) has the actorRef as its
Hi,
I have a use case that I believe Akka Streams may be well suited for, but
I'm not clearly seeing how to implement part of it from reading the
documentation.
I have a single, finite input source from an iterator stream. I want to use
Balance to split this stream into N partitions and then
Hello,
I would like to ask if anyone from Akka Team would like to be Google Summer
of Code mentor this year?
Cheers,
Adam Kozuch
--
Read the docs: http://akka.io/docs/
Check the FAQ:
http://doc.akka.io/docs/akka/current/additional/faq.html
Search the archives:
I think the answer is in the {Scala, Java}Docs of mapAsync:
Transform this stream by applying the given function to each of the
elements as they pass through this processing step. The function returns a
Future and the value of that future will be emitted downstreams. As many
futures as
Are these 1.0-M4 modules intended to be compatible with akka-2.4-SNAPSHOT?
I'm having trouble passing a custom materializer to an
IncommingConnection.handleWithAsyncHandler(). The default materializer
seems to work fine, but I wanted to play with buffer sizes.
implicit val materializer =
Hi Anders,
How are you stopping your actor. There is a difference between
system.stop(actorRef) and actorRef ! PoisonPill.
Calling stop is more direct and will as you say send a message, but that is an
internal system message that will cut the line and be processed before normal
actor
Hi Anupam,
Have you looked at the Reactivve Maps, Activator Tutorial
http://typesafe.com/activator/template/reactive-maps ? It has the Play web
front end talking to the back end using akka clustering.
B/
On 27 February 2015 at 16:20:11, Anupam Sharma (anu.lnmiit.1...@gmail.com)
wrote:
Could
Hi Simeon,
What you are experiencing is this the issue where the local address used to
bind the akka actor system inside the docker container doesn't match up with
the external address that is exposed by the host running docker, and that you
are trying to connect to. Akka will then refuse to
Grr, so it seems that TestActorRef really is incompatible with Stash.
http://stackoverflow.com/questions/18335127
This is a real shame.
On Monday, 2 March 2015 12:35:22 UTC, Sam Halliday wrote:
Wow, I think I figured this out... and it's quite scary.
Stash needs an unbounded mailbox. I
You should use mapAsync instead of map.
On 2 Mar 2015 18:03, kermitas kermi...@gmail.com wrote:
Hello,
as an input I have
Source[PageDetails, Unit]
and I also have method which transform PageDetails to
Future[CategoryVector]:
def categorizePage(page: PageDetails): Future[CategoryVector]
Hello,
as an input I have
Source[PageDetails, Unit]
and I also have method which transform PageDetails to Future[CategoryVector]
:
def categorizePage(page: PageDetails): Future[CategoryVector]
By using map method I can change Source[PageDetails, Unit] to Source[Future[
CategoryVector], Unit]:
Might want to look at this thread.
https://groups.google.com/forum/#!topic/akka-user/wyA4xNfM5LM
--
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
---
Lol. Or not, since you're the OP. Oh well, need more coffee.
On Monday, March 2, 2015 at 10:52:29 AM UTC-8, Jim Hazen wrote:
Might want to look at this thread.
https://groups.google.com/forum/#!topic/akka-user/wyA4xNfM5LM
--
Read the docs: http://akka.io/docs/
Check the FAQ:
Howdy All,
Has anyone had any experience getting an Akka Cluster and Cluster Client
running on Kubernetes, e.g. on Google Container Engine (GCE)?
I note the problem with Akka dropping messages when the host IP address
doesn't match the container virtual IP address.
I note the solution in
THANK YOU Luis!! :) That is what I needed.
Let's imagine that I have just one stream run in one JVM. Do you know how
many futures will be evaluated and wait for completion? You know, I can not
have billion of futures in memory :/. Will this be auto-regulated by back
pressure of if not then
15 matches
Mail list logo
