These are chat archives for akkadotnet/AkkaStreams

22nd
Jun 2016
Marc Piechura
@marcpiechura
Jun 22 2016 08:52
created the PR for the verification so that it can be reviewed while we are waiting for the TCK nuget package
akkadotnet/akka.net#2109
Chris Constantin
@cconstantin
Jun 22 2016 15:51
looks good
@Silv3rcircl3 what do you think about reactive-streams/reactive-streams-dotnet#10
Marc Piechura
@marcpiechura
Jun 22 2016 15:56
Busy right now, will look at it laiter but from the headline I would say no ;-)
Chris Constantin
@cconstantin
Jun 22 2016 15:57
@Silv3rcircl3 what was the location of the RX adapter repo, do you recall?
np
You're searching for this ? :)
Chris Constantin
@cconstantin
Jun 22 2016 16:02
awesome, thanks
Marc Piechura
@marcpiechura
Jun 22 2016 16:05
I have also bookmarked this one
Reactive-Extensions/Rx.NET#19
Mid that's helpful for the disxussion
Chris Constantin
@cconstantin
Jun 22 2016 16:06
thanks. I’ll have to find time to review it in detail
Chris Constantin
@cconstantin
Jun 22 2016 17:21
@Silv3rcircl3 what’s the most complex use of akka-streams (jvm) you’ve seen in the wild? Something that deals with joining heterogenous data sources and has some complex graphs, going beyond the “word count” or “processing tweets” examples?
Marc Piechura
@marcpiechura
Jun 22 2016 17:32
None :) but mostly likely due to the fact that I don't come in contact with any code from the jvm except for akka
Bartosz Sypytkowski
@Horusiath
Jun 22 2016 17:37
@cconstantin I think, that such examples are quite proprietary
it would be easier to ask on one of the akka jvm channels
Chris Constantin
@cconstantin
Jun 22 2016 17:37
Yeah, but I could definitely use some :) I’ve been peeking at some storm examples, but those are quite simple as well
I’ve asked Viktor Klang for some pointers
Bartosz Sypytkowski
@Horusiath
Jun 22 2016 17:39
I've tried to build web crawler entirely on akka-streams, but I'm not sure how it will work (scrapping pages introduce cycles inside graph)
and I don't know what's the state of cycles in our impl
Chris Constantin
@cconstantin
Jun 22 2016 17:41
iirc you’d need to introduce an async boundary with an appropriately sized buffer
Bartosz Sypytkowski
@Horusiath
Jun 22 2016 17:42
yes I used those examples to create test that failed in our implementation ;)
Chris Constantin
@cconstantin
Jun 22 2016 17:43
awesome :)
Marc Piechura
@marcpiechura
Jun 22 2016 17:44
The first solution is working ;) only the last one doesn't
The problem is that the last combine doesn't pull the second broadcast output and therefore broadcast isn't pulling the zip out and it deadlocks
Marc Piechura
@marcpiechura
Jun 22 2016 17:58
If I skip this check the first round is working but then it throws with "can't pull port twice"
That's were I needed to stop my research