Akka.net Streams derping around

Program.cs

namespace StreamingServer
{
    using System;
    using System.Linq;
    using System.Threading.Tasks;
    using Akka.Actor;
    using Akka.Streams;
    using Akka.Streams.Dsl;

    public class Program
    {
        public static async Task Main(string[] args)
        {
            //var source = Source.From(Enumerable.Range(1, 100));
            //using (var system = ActorSystem.Create("system"))
            //using (var materializer = system.Materializer())
            //{
            //    await source.RunForeach(i => Console.WriteLine(i.ToString()), materializer);
            //}

            Startup.StartServerActorSystem();

            for (int i = 1; i <= 1000; i++)
            {
                //StreamingServerActorRefs.DataSourceActor.Tell(new Tuple<DateTime, double>(DateTime.Now, new Random().Next(1, 500)));
                var tuple = new Tuple<DateTime, double>(DateTime.Now, i);
                StreamingServerActorRefs.DataSourceActor.Tell(tuple);
                Console.WriteLine($"{new DateTimeOffset(tuple.Item1).ToUnixTimeMilliseconds().ToString()}, {tuple.Item2}");
            }

            Console.WriteLine("done.");

            Console.ReadKey();
        }
    }
}

rawdata.csv

Startup.Akka.cs

namespace StreamingServer
{
    using System;
    using System.Collections.Generic;
    using System.Globalization;
    using System.IO;
    using Akka.Actor;
    using Akka.Configuration;
    using Akka.IO;
    using Akka.Streams;
    using Akka.Streams.Csv;
    using Akka.Streams.Csv.Dsl;
    using Akka.Streams.Dsl;

    /// <summary>
    /// Startup class to initialise parts of the application
    /// </summary>
    public class Startup
    {
        private static Config configServer = ConfigurationFactory.ParseString(@"
            akka {
                actor {
                    provider = remote
                }
                remote {
                    dot-netty.tcp {
                        port = 9001 #bound to a specific port
                        hostname = localhost
                    }
                }
            }
        ");

        /// <summary>
        /// Initialise and start the server actor system.
        /// </summary>
        public static void StartServerActorSystem()
        {
            var system = StreamingServerActorRefs.System = ActorSystem.Create("StreamingServerActorSystem", configServer);
            var mat = system.Materializer();

            var dataSource = Source.ActorRef<Tuple<DateTime, double>>(5000, OverflowStrategy.Fail);

            var formatter = new CsvFormatter(',', '"', '\\', "\r\n", CsvQuotingStyle.Required);

            var flow = Flow.Create<Tuple<DateTime, double>>()
                .Select(t => formatter
                    .ToCsv(new List<string> {
                        new DateTimeOffset(t.Item1).ToUnixTimeMilliseconds().ToString(),
                        t.Item2.ToString(CultureInfo.InvariantCulture)
                    })
                );

            var file = new FileInfo("rawdata.csv");
            var fileSink = FileIO.ToFile(file);

            var dataSourceActor = StreamingServerActorRefs.DataSourceActor = dataSource.Via(flow).To(fileSink).Run(mat);
        }
    }
}

StreamingServer.csproj

<Project Sdk="Microsoft.NET.Sdk">

  <PropertyGroup>
    <OutputType>Exe</OutputType>
    <TargetFramework>netcoreapp2.1</TargetFramework>
  </PropertyGroup>

  <PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'Debug|AnyCPU' ">
    <LangVersion>Latest</LangVersion>
    <CodeAnalysisRuleSet>..\MindReader.ruleset</CodeAnalysisRuleSet>
    <DocumentationFile>bin\Debug\netcoreapp2.1\StreamingServer.xml</DocumentationFile>
  </PropertyGroup>
  <PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'Release|AnyCPU' ">
    <LangVersion>Latest</LangVersion>
    <CodeAnalysisRuleSet>..\MindReader.ruleset</CodeAnalysisRuleSet>
  </PropertyGroup>
  <ItemGroup>
    <PackageReference Include="Akka.Streams" Version="1.3.9" />
    <PackageReference Include="Akka" Version="1.3.9" />
    <PackageReference Include="Akka.Remote" Version="1.3.9" />
    <PackageReference Include="Akka.Logger.NLog" Version="1.3.3" />
    <PackageReference Include="StyleCop.Analyzers" Version="1.0.2" />
    <PackageReference Include="Microsoft.CodeAnalysis.Analyzers" Version="2.6.1" />
    <PackageReference Include="Microsoft.CodeAnalysis.CSharp" Version="2.9.0" />
    <PackageReference Include="Akka.Streams.Csv" Version="0.1.0" />
  </ItemGroup>
  <ItemGroup>
    <Folder Include="Actors\" />
  </ItemGroup>
</Project>

StreamingServerActorRefs.cs

using Akka.Actor;

namespace StreamingServer
{
    internal static class StreamingServerActorRefs
    {
        internal static ActorSystem System;
        internal static IActorRef DataSourceActor;
    }
}