continuity/Server/Consumers/PacketConsumer.cs

namespace Server.Consumers;

using MassTransit;
using Packets;
using Services;

public class PacketConsumer : IConsumer<RawPacket>
{
    private readonly PacketDistributorService distributorService;

    public PacketConsumer(PacketDistributorService distributorService) => this.distributorService = distributorService;

    public Task Consume(ConsumeContext<RawPacket> context)
    {
        this.distributorService.AddPacket(context.Message);
        return Task.CompletedTask;
    }
}