using Microsoft.Research.Naiad;
using Microsoft.Research.Naiad.Frameworks.DifferentialDataflow;

class Program
{
    public static void Main(string[] args)
    {
        using (Controller controller = NewController.FromArgs(ref args)
        {
            using (Computation computation = controller.NewComputation())
            {
                // Define a computation in terms of collections.
                InputCollection<int> input = computation.NewInputCollection();

                var histogram = input.Count(x => x);

                // A subscription collects the result of the computation, and applies
                // an action to the array of weighted updates.
                Subscription subscription = histogram.Subscribe(changes => { /* ... */ });

                computation.Activate();

                // The OnNext() method takes an IEnumerable<int> that specifies records to add.
                input.OnNext(new int[] { 1, 1, 2, 3, 5, 8 });
                input.Sync(0); 

                input.OnNext(new int[] { 13 });
                input.Sync(1);

                // This OnNext() overload allows elements to be added with integer weights.
                // The weights may be positive (adding records) or negative (removing records).
                input.OnNext(new Weighted<int>[] { new Weighted<int>(1, -2) });
                input.Sync(2);

                computation.Join();
            }

            controller.Join();
        }

    }
}