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

Make CreateNotification for nonexistent variable fail with Exception

Browse Source
This commit is contained in:
Peter Butzhammer
2024-02-07 13:33:50 +01:00
parent c667c113e3
commit 3c39996f5e
1 changed files with 8 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
Sharp7.Rx/Sharp7Plc.cs
View File

@@ -85,8 +85,14 @@ public class Sharp7Plc : IPlc
var disposeableContainer = multiVariableSubscriptions.GetOrCreateObservable(variableName); var disposeableContainer = multiVariableSubscriptions.GetOrCreateObservable(variableName);
disposeableContainer.AddDisposableTo(disposables); disposeableContainer.AddDisposableTo(disposables);
var observable = disposeableContainer.Observable var observable =
.Select(bytes => S7ValueConverter.ConvertToType<TValue>(bytes, address)); // Directly read variable first.
// This will propagate any errors due to reading from invalid addresses.
Observable.FromAsync(() => GetValue<TValue>(variableName))
.Concat(
disposeableContainer.Observable
.Select(bytes => S7ValueConverter.ConvertToType<TValue>(bytes, address))
);
if (transmissionMode == TransmissionMode.OnChange) if (transmissionMode == TransmissionMode.OnChange)
observable = observable.DistinctUntilChanged(); observable = observable.DistinctUntilChanged();