flow actor example.cs

 class Program
    {
        static void Main(string[] args)
        {
            var system = ActorSystem.Create("TestSystem");

            var myActor = system.ActorOf(Props.Create(() => new MyActor());

            using (var materializer = system.Materializer())
            {
                var source = Source.From(Enumerable.Range(1, 100));

                //var sink = Sink.ForEach<int>(x => tcpActor.Tell(x));
                var sink = Sink.ActorRef<int>(tcpActor, "Done");
                
                var runnable = source.ToMaterialized(sink, Keep.Both);
                runnable.Run(materializer);
            }

            Console.ReadLine();
        }
    }

    public class MyActor : ReceiveActor
    {
        public MyActor()
        {
            Receive<string>(s => Console.WriteLine(s));
            Receive<int>(i => Console.WriteLine("Got int: " + i));
        }
    }