Add dispatch handler

Kaioru · Aug 20, 2024 · 4eec7ca · 4eec7ca
1 parent daacc12
commit 4eec7ca
Showing 1 changed file with 5 additions and 4 deletions.
diff --git a/src/app/Edelstein.Application.Server/Services/SystemHostService.cs b/src/app/Edelstein.Application.Server/Services/SystemHostService.cs
@@ -5,6 +5,7 @@
 using Edelstein.Application.Server.Bindings;
 using Edelstein.Common.Network.DotNetty.Transports;
 using Edelstein.Protocol.Gameplay;
+using Edelstein.Protocol.Network.Packets;
 using Edelstein.Protocol.Network.Transports;
 using Edelstein.Protocol.Plugin;
 using Edelstein.Protocol.Services.Dispatch;
@@ -52,11 +53,11 @@ public async Task StartAsync(CancellationToken cancellationToken)
         Subscription = dispatch
             .Subscribe(request)
             .ToObservable()
-            .Select(i =>
+            .Select(async i =>
             {
-                // TODO
-                Console.WriteLine(i);
-                return Task.CompletedTask;
+                using var writer = new RawPacketWriter()
+                    .WriteBytes(i.Payload);
+                await Context.Dispatch(writer);
             })
             .Subscribe();