From 61e04c7f639a74cf948f826f464152d42e487404 Mon Sep 17 00:00:00 2001 From: Peter Butzhammer Date: Tue, 30 Jul 2024 12:19:52 +0200 Subject: [PATCH] Update LinqPad samples --- Sharp7.Rx/linqpad-samples/Create Notification.linq | 2 +- Sharp7.Rx/linqpad-samples/Establish connection.linq | 10 ++++++---- Sharp7.Rx/linqpad-samples/Multiple notifications.linq | 6 +++--- 3 files changed, 10 insertions(+), 8 deletions(-) diff --git a/Sharp7.Rx/linqpad-samples/Create Notification.linq b/Sharp7.Rx/linqpad-samples/Create Notification.linq index 9357004..97d3ebc 100644 --- a/Sharp7.Rx/linqpad-samples/Create Notification.linq +++ b/Sharp7.Rx/linqpad-samples/Create Notification.linq @@ -23,7 +23,7 @@ await plc.InitializeConnection(); // create an IObservable var observable = plc.CreateNotification($"DB{db}.Int6", Sharp7.Rx.Enums.TransmissionMode.OnChange); -observable.Dump(); +_ = observable.Dump(); for (int i = 0; i < 10; i++) { diff --git a/Sharp7.Rx/linqpad-samples/Establish connection.linq b/Sharp7.Rx/linqpad-samples/Establish connection.linq index 8b96b56..5b0b2c9 100644 --- a/Sharp7.Rx/linqpad-samples/Establish connection.linq +++ b/Sharp7.Rx/linqpad-samples/Establish connection.linq @@ -20,10 +20,12 @@ using var plc = new Sharp7Plc(ip, rackNumber, cpuMpiAddress); // Initialize connection await plc.InitializeConnection(); -// wait for connection to be established -await plc.ConnectionState - .FirstAsync(c => c == Sharp7.Rx.Enums.ConnectionState.Connected) - .ToTask(); +// // Alternative: Trigger connection and wait for ConnectionState == Connected +// plc.TriggerConnection(); +// // wait for connection to be established +//await plc.ConnectionState +// .FirstAsync(c => c == Sharp7.Rx.Enums.ConnectionState.Connected) +// .ToTask(); "Connection established".Dump(); diff --git a/Sharp7.Rx/linqpad-samples/Multiple notifications.linq b/Sharp7.Rx/linqpad-samples/Multiple notifications.linq index 6078d74..78c1dae 100644 --- a/Sharp7.Rx/linqpad-samples/Multiple notifications.linq +++ b/Sharp7.Rx/linqpad-samples/Multiple notifications.linq @@ -16,13 +16,13 @@ var cpuMpiAddress = 0; using var plc = new Sharp7Plc(ip, rackNumber, cpuMpiAddress); -plc.ConnectionState.Dump(); +_ = plc.ConnectionState.Dump(); await plc.InitializeConnection(); // create an IObservable -plc.CreateNotification($"DB{db}.Int6", Sharp7.Rx.Enums.TransmissionMode.OnChange).Dump("Int 6"); -plc.CreateNotification($"DB{db}.Real10", Sharp7.Rx.Enums.TransmissionMode.OnChange).Dump("Real 10"); +_ = plc.CreateNotification($"DB{db}.Int6", Sharp7.Rx.Enums.TransmissionMode.OnChange).Dump("Int 6"); +_ = plc.CreateNotification($"DB{db}.Real10", Sharp7.Rx.Enums.TransmissionMode.OnChange).Dump("Real 10");