diff --git a/Sharp7.Rx/Extensions/PlcExtensions.cs b/Sharp7.Rx/Extensions/PlcExtensions.cs index 619dd24..14e3e58 100644 --- a/Sharp7.Rx/Extensions/PlcExtensions.cs +++ b/Sharp7.Rx/Extensions/PlcExtensions.cs @@ -18,7 +18,7 @@ namespace Sharp7.Rx.Extensions var subscriptions = new CompositeDisposable(); var notification = plc - .CreateNotification(triggerAddress, TransmissionMode.OnChange, TimeSpan.Zero) + .CreateNotification(triggerAddress, TransmissionMode.OnChange) .Publish() .RefCount(); diff --git a/Sharp7.Rx/Interfaces/IPlc.cs b/Sharp7.Rx/Interfaces/IPlc.cs index e5c4c89..a438957 100644 --- a/Sharp7.Rx/Interfaces/IPlc.cs +++ b/Sharp7.Rx/Interfaces/IPlc.cs @@ -7,7 +7,7 @@ namespace Sharp7.Rx.Interfaces { public interface IPlc : IDisposable { - IObservable CreateNotification(string variableName, TransmissionMode transmissionMode, TimeSpan cycleSpan); + IObservable CreateNotification(string variableName, TransmissionMode transmissionMode); Task SetValue(string variableName, TValue value); Task GetValue(string variableName); IObservable ConnectionState { get; } diff --git a/Sharp7.Rx/Sharp7Plc.cs b/Sharp7.Rx/Sharp7Plc.cs index a1a7664..fb0a4f4 100644 --- a/Sharp7.Rx/Sharp7Plc.cs +++ b/Sharp7.Rx/Sharp7Plc.cs @@ -153,7 +153,7 @@ namespace Sharp7.Rx } } - public IObservable CreateNotification(string variableName, TransmissionMode transmissionMode, TimeSpan cycleTime) + public IObservable CreateNotification(string variableName, TransmissionMode transmissionMode) { return Observable.Create(observer => {