[akka-user] Akka Typed BehaviorTestKit with TimerScheduler

Hi, We are trying to create a BehaviorTestKit using a behavior which spawns a timer within. val behaviorTestKit = BehaviorTestKit(createBehavior) private def createBehavior(): Behavior[MyMessage] = { Behaviors .withTimers[MyMessage]( timerScheduler ⇒ Behaviors .mu

[akka-user] Question on the WeaklyUp state

Hi, I read the description here: https://doc.akka.io/docs/akka/2.5.5/scala/cluster-usage.html#weaklyup-members 1) When a node is in the weakly up state, does the node process jobs like the nodes of the Up state? 2) In what case is it useful to have akka.cluster.allow-weakly-up-members turned

Re: [akka-user] Akka-Streams and Android

Sorry, it’s been years since I’ve done Android development… Maybe someone else on the list will have insights or ideas where better to ask -- Cheers, Konrad 'ktoso ' Malawski Akka @ Lightbend On March 8, 2018 at 1:58:29, 'Matt' via Akka Us

Re: [akka-user] import context.dispatcher nullpointerexception

Yes it is nulled using unsafe. -- Cheers, Konrad 'ktoso ' Malawski Akka @ Lightbend On March 8, 2018 at 7:32:56, Heiko Seeberger (loe...@posteo.de) wrote: `import context.dispatcher` is what „everybody“ is doing, not? I’m using it all ove

Re: [akka-user] import context.dispatcher nullpointerexception

`import context.dispatcher` is what „everybody“ is doing, not? I’m using it all over the place, because I have learned that one can import from stable identifiers (e.g. vals) in Scala. Hence I don’t think changing the docs has the necessary effect. How can a final val be „nulled"? Unsafe? Refle

Re: [akka-user] import context.dispatcher nullpointerexception

Thanks! On Wed, Mar 7, 2018 at 6:16 PM, Jeff wrote: > An example of documentation for using import context.dispatcher is here > https://doc.akka.io/docs/akka/2.5/futures.html#within-actors > > I can create some PR to update the documentation > > On Wednesday, March 7, 2018 at 6:09:24 AM UTC-8, P

Re: [akka-user] import context.dispatcher nullpointerexception

An example of documentation for using import context.dispatcher is here https://doc.akka.io/docs/akka/2.5/futures.html#within-actors I can create some PR to update the documentation On Wednesday, March 7, 2018 at 6:09:24 AM UTC-8, Patrik Nordwall wrote: > > It's because when the actor is stopped

Re: [akka-user] Akka-Streams and Android

Ah, thanks. That's good to know, too bad. I was thinking about playing around with reactive streams and MVI (Modell-View-Intent). I tried RxScala with RxJava2 and RxAndroid before but I wasn't very successful. So, I thought I give akka-streams a try. Any ideas on how to do MVI with Scala on An

Re: [akka-user] Akka-Streams and Android

Akka requires JDK8, which Android is not AFAIR… they support Java8 syntax nowadays but not JDK8 bytecode right? You could use ancient versions of Akka which would run on JDK6 bytecode, but that’s strongly discouraged. -- Cheers, Konrad 'ktoso ' Malawski Akka @ Li

[akka-user] Akka-Streams and Android

Hi there, I wonder if akka-streams are working on Android. I tried to get it working but there are tons of warnings and notes on the proguard step. I also did some proguard rules but still the estimated method count is >64K (81864); Akka-Streams 23684 alone. Is there a chance to make it work or

Re: [akka-user] Getting the HTTP server's bound port seems to be impossible?

Could I ask you to open a ticket requesting that on https://github.com/akka/akka ? Thanks -- Cheers, Konrad 'ktoso ' Malawski Akka @ Lightbend On March 8, 2018 at 0:21:58, Alan Burlison (alan.burli...@gmail.com) wrote: On 07/03/18 01:11,

Re: [akka-user] Getting the HTTP server's bound port seems to be impossible?

On 07/03/18 01:11, Konrad “ktoso” Malawski wrote: The difference is in the binding call you can do, there’s a few styles, yet each gives back a binding, which contains an address: val bindingFuture = Http().bindAndHandle(routes, interface = "0.0.0.0", port = 8080) bindingFuture.foreach { bindin

[akka-user] Host-level API with queue: How to retry?

Dear all, I am very new to Akka and I am implementing a simple REST HTTP client using Akka. My client should do around 100k GET requests. When I implement it in the naïve way — obviously — I end

Re: [akka-user] import context.dispatcher nullpointerexception

It's because when the actor is stopped some of the fields are cleared (yeah, even though they are vals) to "help" the GC in case something (e.g. an local ActorRef) is still referencing the actor instance. implicit val ec = context.dispatcher would solve it here. Where in the documentation is the