using System.Threading.Tasks.Dataflow;

using System;

using System.Threading;

​

var actor = new Actor();

await actor.Action.SendAsync(2);

await actor.Action.SendAsync(2);

​

actor.Action.Complete();

await actor.Action.Completion.WaitAsync(new CancellationToken());

​

// State Будет = 4

Console.WriteLine($"\n State = {actor.State}");

Console.ReadLine();

public class Actor

{

​

    int state;

    public int State { get { return state; } }

​

    public Actor() {

        Action = new (x =>

            {

                this.state = this.state + x;

            });

​

    }

​

    public ActionBlock<int> Action { get;} 

​

}

​

​