These are chat archives for akkadotnet/AkkaStreams

27th
Jun 2017
Sean Farrow
@SeanFarrow
Jun 27 2017 06:09
How does the following MapAsync call translate (I'm going ot use SelectAsync):
Flow.fromGraph(new SqsFlowStage(queueUrl, sqsClient)).mapAsync(settings.maxInFlight)(identity)
it's the identity portion I'm struggling with--where is this defined?
Marc Piechura
@marcpiechura
Jun 27 2017 06:11
It's basically x => x simple pass through
Sean Farrow
@SeanFarrow
Jun 27 2017 06:37
So would this translate to:
SelectAsync(settings.maxInFlight, x =>x);
Marc Piechura
@marcpiechura
Jun 27 2017 07:07
Exactly
Sean Farrow
@SeanFarrow
Jun 27 2017 12:40
Did the capability to log in a GraphStageLogic get in to 1.2.1? or do we still need ot wait for 1.3?
Marc Piechura
@marcpiechura
Jun 27 2017 13:43
@SeanFarrow need to wait for 1.3, the 1.2.x bug fixes are pulled from the dev branch and the logger was only merged into the v1.3 branch
Sean Farrow
@SeanFarrow
Jun 27 2017 14:27
Thanks, finally did you port Scal.Util.Try or a similar concept, there doesn't appear to be anything in c#/net natively.
Marc Piechura
@marcpiechura
Jun 27 2017 16:25
Some but not all, try is like try catch
Maybe with an empty catch if it does nothing on failure