[akka-user] Re: Simple beginner questions: Accessing values in flows

Hi, could you please spare final code ? -- >> Read the docs: http://akka.io/docs/ >> Check the FAQ: >> http://doc.akka.io/docs/akka/current/additional/faq.html >> Search the archives: https://groups.google.com/group/akka-user --- You received this

[akka-user] Re: [akka-stream] Problems with the shape creation

A custom GraphStage [1] using AmorphousShape is probably the way to go in this case. That's a really neat diagram, BTW! What software did you us to create it? Cheers, Rafał [1] http://doc.akka.io/docs/akka/2.4/scala/stream/stream-customize.html#Custom_processing_with_GraphStage W dniu

[akka-user] Re: [akka-stream] Problems with the shape creation

Hi again, I have a very specific case. My flow looks like this one: The idea of multi input/output shape was to redirect messages to a right output based on the message

[akka-user] Re: Is back pressure triggered upon exceptions

Thanks Johannes for your feedback, For pt. 2 I am handling errors using Supervision.Resume so the stream should technically continue and not complete with an error, correct? Dagny - 1. It is unclear what your graph looks like and how you are materializing the value, also which supervision

[akka-user] graph control events propagation

Hi Akka Team, All, I have few custom stages, recently i find out that one of them under certain conditions was not properly completing graph stage, which was causing graph to run forever. I have timeouts attached to graph and would expect it to fail with timeout but it never happened. I

[akka-user] [akka-http] Issue with rendering when using custom ToEntityMarshaller

I have defined a custom ToEntityMarshaller for type User. When requesting /users it returns an empty JSON array. Only when I remove the implicit def userMarshaller it return the correct representation of the stream. Anybody has a pointer on what is going wrong? import akka.NotUsed import

[akka-user] Re: [akka-stream] Problems with the shape creation

Hi, Rafał! Thanks a lot! You gave me everything I need :) I was looking for AmorphousShape! Thanks again, I will not be inventing a wheel anymore! Regards, Sergey вторник, 18 октября 2016 г., 18:34:22 UTC+3 пользователь Rafał Krzewski написал: > > It's not clear to me, what are you trying

Re: [akka-user] Re: ANNOUNCE: Akka HTTP 3.0.0-RC1

And fixed: https://github.com/akka/akka-http/commit/66adf848b57abdf6803b5713e1787fd23c00ccdb -- Konrad 'ktoso’ Malawski Akka @ Lightbend java.pl / geecon.org / krakowscala.pl / lambdakrk.pl / sckrk.com On 18 October 2016 at 19:44:07,

[akka-user] Re: ANNOUNCE: Akka HTTP 3.0.0-RC1

Congratulations! Is the plan to remove the "experimental" from akka-http-experimental when this moves from RC to final? -- Eric On Monday, October 17, 2016 at 3:22:17 PM UTC-7, Konrad 'ktoso' Malawski wrote: > > Dear hakkers, > > We are proud to announce the first Release Candidate of the

Re: [akka-user] Re: ANNOUNCE: Akka HTTP 3.0.0-RC1

Thanks for noticing, that's bug - fixing it right away. -- Konrad `ktoso` Malawski Akka @ Lightbend On 18 October 2016 at 19:44:03, Eric Swenson (e...@swenson.org) wrote: I thought as much, but the documentation you just posted here:

Re: [akka-user] Re: ANNOUNCE: Akka HTTP 3.0.0-RC1

I thought as much, but the documentation you just posted here: http://doc.akka.io/docs/akka-http/current/scala/http/introduction.html still says: Akka HTTP is provided in a separate jar file, to use it make sure to

Re: [akka-user] Re: ANNOUNCE: Akka HTTP 3.0.0-RC1

Yes, that's what all the fuss is about ;-) In fact, in RC it's already removed: http://search.maven.org/#artifactdetails%7Ccom.typesafe.akka%7Cakka-http%7C3.0.0-RC1%7Cjar For people not tracking this in detail: please note that all other modules other than "the DSL" have been stable for a long

[akka-user] Re: [akka-stream] Problems with the shape creation

It's not clear to me, what are you trying to accomplish. It looks like you are trying to implement AmorphousShape (ie. arbitrary number of open inlets and outlets) on your own, and then a specific variant of it, that has all inlets sharing the same type, and all outlets sharing another type.

[akka-user] Re: [akka-stream] Detect failure in MergeHub

Sure! https://github.com/akka/akka/issues/21693 Le mardi 18 octobre 2016 14:36:35 UTC+2, johannes...@lightbend.com a écrit : > > Hi Victor, > > good point. I think the Scaladoc is wrong there. Could you raise an issue > at akka/akka? > > Johannes > > On Tuesday, October 18, 2016 at 2:28:14 PM

[akka-user] Re: [akka-stream] Detect failure in MergeHub

Hi Victor, good point. I think the Scaladoc is wrong there. Could you raise an issue at akka/akka? Johannes On Tuesday, October 18, 2016 at 2:28:14 PM UTC+2, Victor wrote: > > Hi, > > It's written in the ScalaDoc of the *MergeHub.source* method that: > > If one of the inputs fails the Sink,

[akka-user] [akka-stream] Detect failure in MergeHub

Hi, It's written in the ScalaDoc of the *MergeHub.source* method that: If one of the inputs fails the Sink, the Source is failed in turn But, in the MergeHub source code, the *onUpstreamFailure* method only throw an exception: override def onUpstreamFailure(ex: Throwable): Unit = { throw

[akka-user] Re: [akka-stream] Problems with the shape creation

People say that following article may help: http://degoes.net/articles/insufficiently-polymorphic However, I still don't understand what's wrong with it. Any help will be appreciated. Thanks! Regards, Sergey -- >> Read the docs: http://akka.io/docs/ >> Check the

Re: [akka-user] Re: How to correctly close system when websocket is open?

Hi, thanks, putting Channel(processing).via(killSwitch.flow) and shutting it down later worked! Regards, Andrzej. On Tue, Oct 18, 2016 at 1:23 AM, Rafał Krzewski wrote: > Hi, > just a quick suggestion: mabe a KillSwitch [1] in Channel flow would help? > > cheers, >