ChyronHego.DataEngine 0.3.4

using ChyronHego.DataEngine;
using System;

namespace DataEngineExample
{
    class Program
    {
        private static DataEngine de = new DataEngine();
        private static DataEngine deSignaler = new DataEngine();

        static void Main(string[] args)
        {
            de.Connected += OnDataEngineConnect;
            de.Event += OnDataEngineEvent;
            de.Connect();
            deSignaler.Connect();

            Console.WriteLine("Press enter key to exit\n");
            Console.ReadLine();
        }

        private static void OnDataEngineEvent(DataEngineEvent dataEngineEvent)
        {
            Console.WriteLine($"Received a write / signal on key {dataEngineEvent.Key} in bucket {dataEngineEvent.Bucket}");
            Console.WriteLine($"Value: {dataEngineEvent.Value}");
            Console.WriteLine($"Is Key Delete Event: {dataEngineEvent.IsDeleted}");
        }

        private static async void OnDataEngineConnect()
        {
            var bucket = "MyBucket";
            var key = "MyKey";

            // Write and persist object to Key
            var someObject = new
            {
                Prop = "Value",
                AnotherProp = "AnotherValue",
                YetAnother = 1000
            };
            Console.WriteLine($"Writing .NET object to key {key} in bucket {bucket}\n");
            await de.WriteAsync(bucket, key, someObject);

            // Read Key
            Console.WriteLine($"Reading key {key} from bucket {bucket}");
            var response = await de.ReadAsync(bucket, key);
            Console.WriteLine(response.Value + "\n");

            // Write and persist raw JSON string
            Console.WriteLine($"Writing raw JSON to key {key} in bucket {bucket}\n");
            await de.WriteAsync(bucket, key, "{ \"rawJson\": true }");

            // Read Key
            Console.WriteLine($"Reading key {key} from bucket {bucket}\n");
            response = await de.ReadAsync(bucket, key);
            Console.WriteLine(response.Value + "\n");

            // Delete Key
            Console.WriteLine($"Deleting key {key} from bucket {bucket}\n");
            await de.DeleteAsync(bucket, key);

            // Register for all events on a specific key or set of keys
            // ** NOTE, Writes and signals will not fire on same instance of DataEngine class **
            Console.WriteLine($"Listening for all signals or writes on key {key} in bucket {bucket}\n");
            await de.RegisterEventsAsync(bucket, new[] { key });

            // Signal Key (does not persist in Data Engine)
            var someMessage = new
            {
                Message = "Some data here"
            };
            Console.WriteLine($"Signaling to key {key} in bucket {bucket}\n");
            // *** NOTE USE OF deSignaler instance to signal event ***
            await deSignaler.SignalEvent(bucket, key, someMessage);   
        }
    }
}