RAGECOOP-V/Core/Networking/CoopPeer.cs

using System;
using System.Collections.Generic;
using System.Threading;
using Lidgren.Network;

namespace RageCoop.Core
{
    internal class CoopPeer : NetPeer, IDisposable
    {
        private readonly Thread ListenerThread;
        private bool _stopping;
        public EventHandler<NetIncomingMessage> OnMessageReceived;

        public CoopPeer(NetPeerConfiguration config) : base(config)
        {
            Start();
            NetIncomingMessage msg;
            ListenerThread = new Thread(() =>
            {
                while (!_stopping)
                {
                    msg = WaitMessage(200);
                    if (msg != null) OnMessageReceived?.Invoke(this, msg);
                }
            });
            ListenerThread.Start();
        }

        /// <summary>
        ///     Terminate all connections and background thread
        /// </summary>
        public void Dispose()
        {
            _stopping = true;
            Shutdown("Bye!");
            ListenerThread.Join();
        }

        public void SendTo(Packet p, NetConnection connection, ConnectionChannel channel = ConnectionChannel.Default,
            NetDeliveryMethod method = NetDeliveryMethod.UnreliableSequenced)
        {
            var outgoingMessage = CreateMessage();
            p.Pack(outgoingMessage);
            SendMessage(outgoingMessage, connection, method, (int)channel);
        }

        public void SendTo(Packet p, IList<NetConnection> connections,
            ConnectionChannel channel = ConnectionChannel.Default,
            NetDeliveryMethod method = NetDeliveryMethod.UnreliableSequenced)
        {
            var outgoingMessage = CreateMessage();
            p.Pack(outgoingMessage);
            SendMessage(outgoingMessage, connections, method, (int)channel);
        }

        public void Send(Packet p, IList<NetConnection> cons, ConnectionChannel channel = ConnectionChannel.Default,
            NetDeliveryMethod method = NetDeliveryMethod.UnreliableSequenced)
        {
            var outgoingMessage = CreateMessage();
            p.Pack(outgoingMessage);
            SendMessage(outgoingMessage, cons, method, (int)channel);
        }
    }
}