These are chat archives for akkadotnet/AkkaStreams

5th
Aug 2016
Bartosz Sypytkowski
@Horusiath
Aug 05 2016 12:17
@Silv3rcircl3 no. I've tried to implement Azure event hub / service bus streams based on their counterparts in JVM (rabbitmq and kafka), but it seems, that it's not quite possible, because some GraphStageLogic methods should be able to be overriden to implement some behaviors but they aren't virtual on .NET side
haven't looked deeply into the issues though
btw. great work with Akka.Streams.Azure :D
Konrad `ktoso` Malawski
@ktoso
Aug 05 2016 13:29
pardon my popping in :)
what's akka streams azure :)
fun fact: "reactive streams in elixir" is basically me explaining it to Jose the last year or so ;)
Marc Piechura
@marcpiechura
Aug 05 2016 13:33
Nothing fancy, only source's and sink's for Azure Storage Queue, EventHub and ServiceBus ;) https://github.com/Silv3rcircl3/Akka.Streams.Azure
Konrad `ktoso` Malawski
@ktoso
Aug 05 2016 13:33
ok, at least he mentions "there's a lot of inspiration from akka streams"
too bad it's not in the text...
This message was deleted
may just ping him to note that :)
Marc Piechura
@marcpiechura
Aug 05 2016 13:41
@Horusiath I see, I have implemented a directory source and faced the same problem with the missing "ack". The problem is that I need to delete or move the file at some point in the stream but even if I use the next stage for it, it's possible that the source reads the files before the delete is happen. So my plan was to keep track of the files and only push new files and use a backchannel to signal that the file was processed and can be removed from the list
I thought that I could simply use a FlowShape which would only be usable within a graph, since both the in and output are on the "right" side, so to speak ;)
Konrad `ktoso` Malawski
@ktoso
Aug 05 2016 13:54
thanks for the link! will have a look :) @Silv3rcircl3
Marc Piechura
@marcpiechura
Aug 05 2016 13:56
You know it's for akka.net ? :)
Konrad `ktoso` Malawski
@ktoso
Aug 05 2016 13:56
sure :)
still want to have a look :)
Marc Piechura
@marcpiechura
Aug 05 2016 13:56
Alright ;)