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

Wait for connection before setting up notification

Browse Source
This commit is contained in:
Peter Butzhammer
2024-07-30 12:13:50 +02:00
parent 79031d6f1c
commit a2b6d84862
1 changed files with 7 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
Sharp7.Rx/Sharp7Plc.cs
View File

@@ -105,9 +105,13 @@ public class Sharp7Plc : IPlc
disposableContainer.AddDisposableTo(disp); disposableContainer.AddDisposableTo(disp);
var observable = var observable =
// Read variable with GetValue first. ConnectionState
// This will propagate any errors due to reading from invalid addresses. // Wait for connection to be established
Observable.FromAsync(() => GetValue<TValue>(variableName)) .FirstAsync(c => c == Enums.ConnectionState.Connected)
// Read variable with GetValue first.
// This will propagate any errors due to reading from invalid addresses.
.SelectMany(_ => GetValue<TValue>(variableName))
// Output results from read loop
.Concat( .Concat(
disposableContainer.Observable disposableContainer.Observable
.Select(bytes => ValueConverter.ReadFromBuffer<TValue>(bytes, address)) .Select(bytes => ValueConverter.ReadFromBuffer<TValue>(bytes, address))