I am trying to update a spray sample to work with akka-http, first try.
It's not immediately obvious to me how I should associate state data with a
client connection in my service. Could someone clarify? I may have missed
it in the documentation, so I apologize in advance.
What I need to
Hi
Your response is crucial because I try to check if Akka stream can fit our
application.
We can't just think about a linear flow of event where there is only
transformation from object1 to object2
*We've to make some job of Group of object from the flow. *
For example we need to compare
Hi,
While I am implementing a multi-agent system application, I investigate
akka.agent.Agent and I didn't notice any relation between agent in akka and
the well known multi-agent concepts. Could anyone has an idea about that?
Manar,
--
--
>> Read the docs:
D'oh!
After clicking on the Scala documentation link then searching for Flow, I
then clicked on the Flow object in the java.dsl package instead of
scala.dsl. I guess since I had started from the Scala documentation link I
wasn't expecting Java stuff in the package hierarchy.
I see the apply()
Apologies if this is a dumb question
I can do this:
def augmentIntervals(extras: Extras):Flow[Interval, IntervalPlus, Unit] =
Flow[Interval].map { e => IntervalPlus(e, extras) }
Where does the Flow[Interval] come from? I don't see an apply method in the
scaladocs for companion object Flow.
Hi Guys,
So my system has been up and running for quite some time, but suddenly
everything stopped working yesterday and i got this message:
ERROR akka.remote.Remoting akka.remote.Remoting - Association to
[akka.tcp://system@ip:port] with UID [-] irrecoverably failed. Quarantining
address.