Re: [akka-user] Akka Stream Getting Stuck (2.4.9-RC2)

Hi, On Wed, Aug 10, 2016 at 10:26 PM, tigerfoot wrote: > For whoever finds this thread and struggles with the same problem... I've > found a solution that fixed it for me. > > implicit val materializer = ActorMaterializer( > ActorMaterializerSettings(system) >

Re: [akka-user] Akka Stream Getting Stuck (2.4.9-RC2)

For whoever finds this thread and struggles with the same problem... I've found a solution that fixed it for me. implicit val materializer = ActorMaterializer( ActorMaterializerSettings(system) .withAutoFusing(false) // flows with LateKafka get messed up if this is true! )

Re: [akka-user] Akka Stream Getting Stuck (2.4.9-RC2)

Hi guys, Yeah, I knew the first thing ya'll would need is a reproducer, but sadly its wired into a lot of heavy complexity, and... I can't even reproduce it consistently. It sometimes fails. I haven't (consciously) set auto-fusing or fuzzing--it's whatever the defaults are out-of-the-box.

Re: [akka-user] Akka Stream Getting Stuck (2.4.9-RC2)

Hi Greg, On Sat, Aug 6, 2016 at 1:11 AM, tigerfoot wrote: > I'm having a nasty issue I hope someone can help me with. > > I have some stream code like this: > > val contentAssembly = Flow[CRec].map { crec => > println("HERE!") > val x =

[akka-user] Akka Stream Getting Stuck (2.4.9-RC2)

I'm having a nasty issue I hope someone can help me with. I have some stream code like this: val contentAssembly = Flow[CRec].map { crec => println("HERE!") val x = expression.render(crec.value).asInstanceOf[Message[OutputWrapper]] println("X is "+x) (crec,