using System;

using System.Threading.Tasks;

​

public class Program

{

    public static void Main()

    {

        var u = new User(){ Id = Guid.NewGuid(), Name = "John" };

        new UserRepository().AddUser(u);

        Console.WriteLine("User created");

    }

    public class User

    {

        public Guid Id{ get; set; }

        public string Name { get; set;}

    }

    public class UserRepository

    {

        public void AddUser(User u)

        {

            // connect to database and store the user

            new EventHub().UserCreatedEventAsync(u).GetAwaiter().GetResult();

        }

        public User ReadById(Guid id)

        {

            // get user and return from db

            return new User(){ Id = id };

        }

    }

    public class EventHub

    {

        public Task UserCreatedEventAsync(User u)

        {

            // send event with carriage state event

            return Task.CompletedTask;

        }

    }

}