Updated to Rx4.1.1, fixed memory leak with the IsOpen ReadOnlyReactiv…

…eProperty, Seperated into two Elements, IsOpen as a bool and IsOpenObservable as a IObservable bool

SerialPortRx/ISerialPortRx.cs

@@ -49,7 +49,13 @@ public interface ISerialPortRx : IDisposable
         /// Gets the is open.
         /// </summary>
         /// <value>The is open.</value>
-        IReadOnlyReactiveProperty<bool> IsOpen { get; }
+        bool IsOpen { get; }
+
+        /// <summary>
+        /// Gets the is open observable.
+        /// </summary>
+        /// <value>The is open observable.</value>
+        IObservable<bool> IsOpenObservable { get; }
 
         /// <summary>
         /// Gets or sets the parity.

SerialPortRx/Properties/AssemblyInfo.cs

@@ -3,13 +3,13 @@
 
 [assembly: AssemblyTitle("SerialPortRx")]
 [assembly: AssemblyDescription("An Observable Com port extension of System.IO.Ports.SerialPort")]
-[assembly: AssemblyConfiguration(".Net 4.7.1")]
+[assembly: AssemblyConfiguration(".Net 4.6.1")]
 [assembly: AssemblyCompany("ChrisPulman")]
 [assembly: AssemblyProduct("SerialPortRx")]
 [assembly: AssemblyCopyright("Copyright © https://github.com/ChrisPulman 2018")]
 [assembly: AssemblyTrademark("")]
 [assembly: AssemblyCulture("")]
 [assembly: ComVisible(false)]
 [assembly: Guid("cda3585b-d3d6-4be4-9a6b-582ab5de0b8f")]
-[assembly: AssemblyVersion("1.2.0")]
-[assembly: AssemblyFileVersion("1.2.0")]
+[assembly: AssemblyVersion("1.3.0")]
+[assembly: AssemblyFileVersion("1.3.0")]

SerialPortRx/SerialPortRx.cs

@@ -202,7 +202,13 @@ public SerialPortRx()
         /// <value>The is open.</value>
         [Browsable(true)]
         [MonitoringDescription("IsOpen")]
-        public IReadOnlyReactiveProperty<bool> IsOpen => isOpen.ToReadOnlyReactiveProperty();
+        public bool IsOpen => isOpen.Value;
+
+        /// <summary>
+        /// Gets the is open observable.
+        /// </summary>
+        /// <value>The is open observable.</value>
+        public IObservable<bool> IsOpenObservable => Observable.Create<bool>(obs => isOpen.Subscribe(obs));
 
         /// <summary>
         /// Gets or sets the parity.
@@ -309,7 +315,7 @@ from data in port.ReadExisting()
             });
         }).OnErrorRetry((Exception ex) => errors.OnNext(ex)).Publish().RefCount();
 
-        private IReactiveProperty<bool> isOpen { get; } = new ReactiveProperty<bool>();
+        internal IReactiveProperty<bool> isOpen { get; } = new ReactiveProperty<bool>();
 
         /// <summary>
         /// Closes this instance.

SerialPortRx/SerialPortRx.csproj

@@ -9,7 +9,7 @@
     <AppDesignerFolder>Properties</AppDesignerFolder>
     <RootNamespace>CP.IO.Ports</RootNamespace>
     <AssemblyName>SerialPortRx</AssemblyName>
-    <TargetFrameworkVersion>v4.7.1</TargetFrameworkVersion>
+    <TargetFrameworkVersion>v4.6.1</TargetFrameworkVersion>
     <FileAlignment>512</FileAlignment>
     <TargetFrameworkProfile />
   </PropertyGroup>
@@ -35,6 +35,9 @@
     <TreatWarningsAsErrors>true</TreatWarningsAsErrors>
     <DocumentationFile>bin\Release\SerialPortRx.XML</DocumentationFile>
   </PropertyGroup>
+  <PropertyGroup>
+    <AutoGenerateBindingRedirects>true</AutoGenerateBindingRedirects>
+  </PropertyGroup>
   <ItemGroup>
     <Compile Include="ISerialPortRx.cs" />
     <Compile Include="Properties\AssemblyInfo.cs" />
@@ -58,7 +61,7 @@
   </ItemGroup>
   <ItemGroup>
     <PackageReference Include="RxProperty">
-      <Version>5.3.0</Version>
+      <Version>5.3.2</Version>
     </PackageReference>
   </ItemGroup>
   <ItemGroup>

SerialPortRx/SerialPortRx.nuspec

@@ -12,10 +12,10 @@
     <copyright>Copyright © $author$ 2018</copyright>
     <projectUrl>https://github.com/chrispulman/SerialPortRx</projectUrl>
     <dependencies>
-      <dependency id="RxProperty" version="5.3.0" />
+      <dependency id="RxProperty" version="5.3.2" />
     </dependencies>
   </metadata>
   <files>
-    <file src="bin\$configuration$\$id$.pdb" target="lib\net471\" />
+    <file src="bin\$configuration$\$id$.pdb" target="lib\net461\" />
   </files>
 </package>

SerialPortRx/SerialPortRxMixins.cs

@@ -261,7 +261,7 @@ public static IObservable<TSource> OnErrorRetry<TSource, TException>(this IObser
         /// <returns></returns>
         public static IObservable<bool> WhileIsOpen(this SerialPortRx @this, TimeSpan timespan) =>
             Observable.Defer(() => Observable.Create<bool>(obs => {
-                var isOpen = Observable.Interval(timespan).CombineLatest(@this.IsOpen.DistinctUntilChanged(), (a, b) => b).Where(x => x);
+                var isOpen = Observable.Interval(timespan).CombineLatest(@this.isOpen, (a, b) => b).Where(x => x);
                 return isOpen.Subscribe(obs);
             }));
     }