Refactored where incoming data packets are processed

HakanL · Jan 24, 2025 · 9bebffe · 9bebffe
1 parent 7055a6a
commit 9bebffe
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 3 deletions.
diff --git a/src/ArtNetClient.cs b/src/ArtNetClient.cs
@@ -46,8 +46,14 @@ public SendData(IPEndPoint destination)
     //public event EventHandler<NewPacketEventArgs<RdmPacket>> NewRdmPacket;
     //public event EventHandler<NewPacketEventArgs<RdmPacket>> RdmPacketSent;
 
-    public ArtNetClient(IPAddress localAddress, IPAddress localSubnetMask, int port = DefaultPort, UId? rdmId = null)
-            : base(ArtNetPacket.MAX_PACKET_SIZE)
+    public ArtNetClient(
+        IPAddress localAddress,
+        IPAddress localSubnetMask,
+        Func<ReceiveDataPacket, Task>? channelWriter = null,
+        Action? channelWriterComplete = null,
+        int port = DefaultPort,
+        UId? rdmId = null)
+            : base(ArtNetPacket.MAX_PACKET_SIZE, channelWriter, channelWriterComplete)
     {
         RdmId = rdmId ?? UId.Empty;
 
@@ -66,6 +72,8 @@ public ArtNetClient(IPAddress localAddress, IPAddress localSubnetMask, int port
         this.sendSocket.Bind(new IPEndPoint(localAddress, 0));
 
         this.sendSocket.SetSocketOption(SocketOptionLevel.Socket, SocketOptionName.Broadcast, 1);
+
+        StartReceive();
     }
 
     /// <summary>

diff --git a/src/Haukcode.ArtNet.csproj b/src/Haukcode.ArtNet.csproj
@@ -37,7 +37,7 @@
     <ProjectReference Include="..\..\Haukcode.HighPerfComm\src\Haukcode.HighPerfComm.csproj" />
   </ItemGroup>
   <ItemGroup Condition="'$(UseProjectReference)' != 'true'">
-    <PackageReference Include="Haukcode.HighPerfComm" Version="1.0.19" />
+    <PackageReference Include="Haukcode.HighPerfComm" Version="1.0.20" />
   </ItemGroup>
 
   <Target Name="CopyProjectReferencesToPackage" DependsOnTargets="ResolveReferences">