using System;
using MitsubishiRx;

class Program
{
    static void Main()
    {
        // Initialize the PLC driver
        var plc = new MitsubishiPlc("192.168.0.100", MitsubishiProtocolType.MCProtocol);
        
        // Connect to the PLC
        plc.Connect();

        // Read data from a device
        var data = plc.ReadDevice("D100");
        Console.WriteLine($"Value of D100: {data}");

        // Write data to a device
        plc.WriteDevice("D100", 123);
        Console.WriteLine("Value written to D100.");

        // Disconnect from the PLC
        plc.Disconnect();
    }
}

using System;
using System.Reactive.Linq;
using MitsubishiRx;

class Program
{
    static void Main()
    {
        // Initialize the PLC driver
        var plc = new MitsubishiPlc("192.168.0.100", MitsubishiProtocolType.MCProtocol);

        // Connect to the PLC
        plc.Connect();

        // Observe changes on a specific device
        var deviceObservable = plc.Observe("D100");

        // Subscribe to the observable to react to changes
        var subscription = deviceObservable.Subscribe(value =>
        {
            Console.WriteLine($"D100 changed to: {value}");
        });

        // Simulate a delay for demonstration purposes
        Console.WriteLine("Observing changes. Press any key to stop...");
        Console.ReadKey();

        // Dispose of the subscription and disconnect
        subscription.Dispose();
        plc.Disconnect();
    }
}