These are chat archives for akkadotnet/AkkaStreams

19th
Oct 2016
Roger Johansson
@rogeralsing
Oct 19 2016 15:08 UTC
I'm trying to wrap my head around streams. Source.Repeat(1).Take(1000); this is only the definition of the source, right?
and the Sink is what will be applied over the source, inside the materializer?
Vagif Abilov
@object
Oct 19 2016 15:09 UTC
Yepp. E.g. Source.To(sink).Run(materializer)
E.g.:
var source = Source.From(Enumerable.Range(11, 3));
var sink = Sink.ForEach<int>(Console.WriteLine);
var runnable = source.To(sink);
runnable.Run(materializer);
Marc Piechura
@marcpiechura
Oct 19 2016 16:25 UTC
Until you call Run you only have a blueprint of your stream/graph which can be reused multiple times. When you call Run the materializer creates and connects the actors that are needed for this blueprint and actually runs the stream
Roger Johansson
@rogeralsing
Oct 19 2016 18:55 UTC
and a graph is many streams and/or other graphs?
Bartosz Sypytkowski
@Horusiath
Oct 19 2016 19:09 UTC
@rogeralsing it's more like a stream is a specific kind of graph ;)
Roger Johansson
@rogeralsing
Oct 19 2016 20:03 UTC
ok