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

Rename variable

Browse Source
This commit is contained in:
Peter Butzhammer
2024-02-07 13:34:12 +01:00
parent 3c39996f5e
commit d4a8ef9cb3
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
Sharp7.Rx/Sharp7Plc.cs
View File

@@ -81,9 +81,9 @@ public class Sharp7Plc : IPlc
var address = varaibleNameParser.Parse(variableName);
if (address == null) throw new ArgumentException("Input variable name is not valid", nameof(variableName));
var disposables = new CompositeDisposable();
var disp = new CompositeDisposable();
var disposeableContainer = multiVariableSubscriptions.GetOrCreateObservable(variableName);
disposeableContainer.AddDisposableTo(disposables);
disposeableContainer.AddDisposableTo(disp);
var observable =
// Directly read variable first.
@@ -98,9 +98,9 @@ public class Sharp7Plc : IPlc
observable = observable.DistinctUntilChanged();
observable.Subscribe(observer)
.AddDisposableTo(disposables);
.AddDisposableTo(disp);
return disposables;
return disp;
});
}