Program.cs

using System;
using System.Threading.Tasks;
using Common;
using Proto;
using Proto.Remote;
using Proto.Remote.GrpcNet;
using static Proto.Remote.RemoteConfig;
using static System.Threading.Channels.Channel;

var system = new ActorSystem().WithRemote(BindToLocalhost(8000));
await system.Remote().StartAsync();

var channel = CreateUnbounded<MyMessage>();
_ = ChannelPublisher.StartNew(system.Root, channel, "publisher");

//produce messages
for (var i = 0; i < 30; i++)
{
    Console.WriteLine("Sending message " + i);
    await channel.Writer.WriteAsync(new MyMessage(i));
    await Task.Delay(1000);
}