Ensure parse is applied on the right register

SainsburyWellcomeCentre · Oct 24, 2023 · f784a81 · f784a81
1 parent 3676983
commit f784a81
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/src/Aeon.Environment/Aeon.Environment.csproj b/src/Aeon.Environment/Aeon.Environment.csproj
@@ -7,7 +7,7 @@
     <PackageTags>Bonsai Rx Project Aeon Environment</PackageTags>
     <TargetFramework>net472</TargetFramework>
     <VersionPrefix>0.1.0</VersionPrefix>
-    <VersionSuffix>build231011</VersionSuffix>
+    <VersionSuffix>build231012</VersionSuffix>
   </PropertyGroup>
 
   <ItemGroup>

diff --git a/src/Aeon.Environment/ParseRfidMeasurement.cs b/src/Aeon.Environment/ParseRfidMeasurement.cs
@@ -10,14 +10,14 @@
 namespace Aeon.Environment
 {
     [Description("Generates a sequence of spatialized detection events when a tag enters the area of the reader.")]
-    public class ParseRfidMeasurement : Transform<HarpMessage, Timestamped<RfidMeasurement>>
+    public class ParseRfidMeasurement : Combinator<HarpMessage, Timestamped<RfidMeasurement>>
     {
         [Description("The location to associate with each detection event.")]
         public Point2f Location { get; set; }
 
         public override IObservable<Timestamped<RfidMeasurement>> Process(IObservable<HarpMessage> source)
         {
-            return source.Select(message =>
+            return source.Where(InboundDetectionId.Address).Select(message =>
             {
                 var (tagId, timestamp) = InboundDetectionId.GetTimestampedPayload(message);
                 return Timestamped.Create(new RfidMeasurement(Location, tagId), timestamp);