Hi guys,
I'm trying to work out the following problem. Let me first describe the
scenario. I have an actor that loops over a specific set of numbers.
val someActor = system.actorOf(Props(new Actor {
var i = 1
def receive = {
case x: Int =>
log.info("Actor message is: " +
Hi,
I've been working on a service that connects to a tool called GNIP that
streams tweets through a TCP connection. I have two services that
independently connect to GNIP and yesterday both of them went
simultaneously down. I checked nestat and saw that the tcp connection was
gone which made
Hello,
I'm uncertain whether this is the correct place for my question since it
falls in the middle between Akka Streams, Slick 3.0 and Futures in Scala
but I will give it a shot. Please excuse me if you think otherwise.
First about the scenario. I have a flow whose purpose is to create some
Hi Konrad,
Thanks for the reply!
You're right that we should explain what it is on the integrations page
(would you like to submit a PR to help us with that? a :ref: link to the
quickstart would help I think).
Of course, I'd like to help. Are these docs stored in the akka/akka github
Hello,
Before I explain my question I want to say I tried looking for a problem
previously explored which relates to mine but didn't find anything. If I am
mistaken please excuse me and if possible provide me with a link to the
right thread :)
I'm new to Akka Streams and am currently
