maier_st/Sharp7Reactive
1
0
Fork 0
mirror of https://github.com/evopro-ag/Sharp7Reactive.git synced 2025-12-15 11:22:52 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Update LinqPad samples

Browse Source
This commit is contained in:
Peter Butzhammer
2024-04-26 10:01:58 +02:00
parent e52c81683b
commit 6917295cf1
4 changed files with 4 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
Sharp7.Rx/linqpad-samples/Create Notification.linq
View File

@@ -16,10 +16,7 @@ var cpuMpiAddress = 0;
using var plc = new Sharp7Plc(ip, rackNumber, cpuMpiAddress);
await plc.InitializeAsync();
await plc.ConnectionState
.FirstAsync(c => c == Sharp7.Rx.Enums.ConnectionState.Connected)
.ToTask();
await plc.InitializeConnection();
"Connection established".Dump();

2
Sharp7.Rx/linqpad-samples/Establish connection.linq
View File

@@ -18,7 +18,7 @@ var cpuMpiAddress = 0;
using var plc = new Sharp7Plc(ip, rackNumber, cpuMpiAddress);
// Initialize connection
await plc.InitializeAsync();
await plc.InitializeConnection();
// wait for connection to be established
await plc.ConnectionState

5
Sharp7.Rx/linqpad-samples/Multiple notifications.linq
View File

@@ -18,10 +18,7 @@ using var plc = new Sharp7Plc(ip, rackNumber, cpuMpiAddress);
plc.ConnectionState.Dump();
await plc.InitializeAsync();
await plc.ConnectionState
.FirstAsync(c => c == Sharp7.Rx.Enums.ConnectionState.Connected)
.ToTask();
await plc.InitializeConnection();
// create an IObservable
plc.CreateNotification<short>($"DB{db}.Int6", Sharp7.Rx.Enums.TransmissionMode.OnChange).Dump("Int 6");

5
Sharp7.Rx/linqpad-samples/Write and read value.linq
View File

@@ -16,10 +16,7 @@ var cpuMpiAddress = 0;
using var plc = new Sharp7Plc(ip, rackNumber, cpuMpiAddress);
await plc.InitializeAsync();
await plc.ConnectionState
.FirstAsync(c => c == Sharp7.Rx.Enums.ConnectionState.Connected)
.ToTask();
await plc.InitializeConnection();
"Connection established".Dump();