From 4eec7cafa8451d69cd813ad5d2f94a9246546dd3 Mon Sep 17 00:00:00 2001 From: Kaioru Date: Tue, 20 Aug 2024 22:56:40 +0800 Subject: [PATCH] Add dispatch handler --- .../Services/SystemHostService.cs | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) diff --git a/src/app/Edelstein.Application.Server/Services/SystemHostService.cs b/src/app/Edelstein.Application.Server/Services/SystemHostService.cs index 23647d911..982faa419 100644 --- 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();