These are chat archives for akkadotnet/AkkaStreams

23rd
Sep 2018
Marc Piechura
@marcpiechura
Sep 23 2018 07:32 UTC
The reason is that without sending Success message the stream never finishes because it doesn’t known that you only want to write 1000 entries instead of 100000 and as you have figured out there is a chunk size of 8192 by default https://github.com/akkadotnet/akka.net/blob/dev/src/core/Akka.Streams/Dsl/FileIO.cs#L38 . So the remaining lines are kept in the buffer waiting for either complete message or more data but neither is coming when you doesn’t send the success message.
Marc Piechura
@marcpiechura
Sep 23 2018 07:38 UTC
Ok that’s the wrong overload 😂but I guess ToFile has a buffer internally ;-)
Thomas Lazar
@thomaslazar
Sep 23 2018 10:39 UTC
yeah... i now explicitely tell the source actor it's done and stop the actor system... would've done that anyways... well at least the killing off the actor system bit anyways when actually using this stuff.
AndreSteenbergen
@AndreSteenbergen
Sep 23 2018 10:39 UTC
Basically @thomaslazar needs to wait for more data, or close the stream.
Thomas Lazar
@thomaslazar
Sep 23 2018 10:40 UTC
so thanks for the help y'all :)