Re: [akka-user] Stream Testkit expectNextType ?

Thanks, Derek On Sun, Apr 10, 2016 at 2:02 PM, Derek Wyatt wrote: > Alright. I'll play around with these over the next few days and send you a > PR. > > On Fri, Apr 8, 2016 at 12:12 PM Patrik Nordwall > wrote: > >> Hi Derek, >> Sounds like a great addition. Will you take a stab at it? >> /Patri

Re: [akka-user] Re: Akka Persistence: Where do the execution of the Command Goes when it is not simply a state update

Thank you very much. Yes it does. Pretty much what I needed to know. I believe now the question is more about how to deal with making it non blocking. The call to an external service should not block the thread. Hence will be a future. But to not block on that, one needs some specific code for tha

[akka-user] Akka stream - design of Bidi flow between client/server

Hi there, I am trying to design a Bidi Flow between a client and server. The idea is for the server (upon receiving a TCP inbound connection) start sending data ("Hello" messages) on a interval of every 2 seconds to the connected client. The client also sends "Ping" messages (every 5 seconds) a

Re: [akka-user] [akka-http-experimental] Testkit not published

For reference: http://mvnrepository.com/artifact/com.typesafe.akka/akka-http-testkit_2.11 On Sat, Apr 9, 2016 at 2:53 PM, Konrad Malawski < konrad.malaw...@lightbend.com> wrote: > Because its not experimental anymore :) > Trim that word > On Apr 9, 2016 13:49, "Luis Ángel Vicente Sánchez" < > lan

[akka-user] Automatically stream/chunk response

Hi all, I have an akka-http server which responds to certain requests with JSON and sometimes the JSON can be very large (marshalled using https://github.com/hseeberger/akka-http-json/tree/master/akka-http-json4s). I get the impression the response is wrapped in a HttpEntity Strict so can not

Re: [akka-user] Automatically stream/chunk response

HttpEntity has an apply method taking a ContentType and a Source[ByteString,Any] which returns a Chunked entity. Each element returned by the source is encoded as a chunk in the HTTP response. This is not 'automatic' per se, but it exposes explicit control over chunking. - Arno Am 11.04.2016 um

[akka-user] Akka streams: stage that combines consecutive elements

I have a Source of element type A, and I am looking for a way to build a stage combining several of them into elements of type B. This is done based on size and count, and an 'incomplete' instance of B needs to be generated at the end of the stream. Source.mapConcat() with a buffering function tha

[akka-user] Diffing streams

I need to compare two streams of timeseries data. I thought of doing something with zip() but in the case where the data is missing in one stream at the beginning or end, I'd like to keep going. Of course, I could just make the base stream a time stream, and use non-streaming techniques to fetch th

[akka-user] Split Brain?

I noticed that 2.4.4 had some work on the Split Brain Resolver. Is this going to be OSS or remain commercial? I have recently seen the dreaded split brain, and need to implement a workaround. A shared quorum value should be sufficient for my purposes. Also, just curious, is there anyway that

Re: [akka-user] local and remote actors configuration with groups advice/help needed

Hi! Thanks for your help, it pointed me into the right direction. I did not remember that when using context.actorOf then the created actor was relative to current actor context, it has all the sense in the world. I have read the docs but i guess i need more practice to connect the ideas. I reali

Re: [akka-user] Split Brain?

On Tue, Apr 12, 2016 at 1:20 AM, Paul Cleary wrote: > I noticed that 2.4.4 had some work on the Split Brain Resolver. Is this > going to be OSS or remain commercial? > It's right that we in this sprint are extracting Lightbend's Split Brain Resolver