Re: [akka-user] Entity streaming

2016-11-21 Thread Richard Rodseth
Good to know! I will have case classes anyway. On Mon, Nov 21, 2016 at 9:55 AM, Konrad Malawski < konrad.malaw...@typesafe.com> wrote: > You have sadly bumped into an weird edge case here, this API was designed > mostly for streaming case classes in mind, > as streaming primitives may be a nice h

Re: [akka-user] Entity streaming

2016-11-21 Thread Konrad Malawski
You have sadly bumped into an weird edge case here, this API was designed mostly for streaming case classes in mind, as streaming primitives may be a nice hello world but rarely is the thing one wants I think... To workaround the limitation you can provide an explicit marshaller that exposes the S

Re: [akka-user] Future#mapTo versus Future.successful#mapTo?

2016-11-21 Thread Viktor Klang
On Mon, Nov 21, 2016 at 5:23 PM, Kevin Meredith wrote: > Given: > > $scala > Welcome to Scala 2.11.8 (Java HotSpot(TM) 64-Bit Server VM, Java > 1.8.0_101). > Type in expressions for evaluation. Or try :help. > > import scala.concurrent.Future > import scala.concurrent.ExecutionContext.Implicits.g

[akka-user] Future#mapTo versus Future.successful#mapTo?

2016-11-21 Thread Kevin Meredith
Given: $scala Welcome to Scala 2.11.8 (Java HotSpot(TM) 64-Bit Server VM, Java 1.8.0_101). Type in expressions for evaluation. Or try :help. import scala.concurrent.Future import scala.concurrent.ExecutionContext.Implicits.global Why does `Future[Any]#mapTo` appear to behave differently than `F

[akka-user] Node Roll Error with Distributed Data.

2016-11-21 Thread kraythe
Greetings, After having some issues with akka persistence when rolling nodes. Since we only use persistence for the cluster sharding coordinator, I decided to try out the Distributed Data module and I am getting the following error on all my cluster sharded actors. This happens right before th

Re: [akka-user] Entity streaming

2016-11-21 Thread Konrad Malawski
Thanks for reporting Richard - seems there's a bug somewhere, I'm looking into it. Seems it doesn't compose nicely with existing predefined primitive marshallers (like String here), if it was wrapped in a type (say Thing("One") then it works, which is what all our tests were doing). Please track t

Re: [akka-user] Akka Agent for Scala 2.12

2016-11-21 Thread Patrik Nordwall
Thanks, we have it in progress here: https://github.com/akka/akka/pull/21868 Will be included in next Akka release. On Mon, Nov 21, 2016 at 6:05 AM, Ian de Beer wrote: > Hi Patrik > 2016 Nov 17 — ScalaSTM version 0.8 released, including > • added 2.12 build > • small TxnLocal improvements > • co