39 lines
953 B
C#
39 lines
953 B
C#
using System.Collections.Generic;
|
|
|
|
namespace LiteNetLib
|
|
{
|
|
internal sealed class SimpleChannel
|
|
{
|
|
private readonly Queue<NetPacket> _outgoingPackets;
|
|
private readonly NetPeer _peer;
|
|
|
|
public SimpleChannel(NetPeer peer)
|
|
{
|
|
_outgoingPackets = new Queue<NetPacket>();
|
|
_peer = peer;
|
|
}
|
|
|
|
public void AddToQueue(NetPacket packet)
|
|
{
|
|
lock (_outgoingPackets)
|
|
{
|
|
_outgoingPackets.Enqueue(packet);
|
|
}
|
|
}
|
|
|
|
public bool SendNextPackets()
|
|
{
|
|
NetPacket packet;
|
|
lock (_outgoingPackets)
|
|
{
|
|
while (_outgoingPackets.Count > 0)
|
|
{
|
|
packet = _outgoingPackets.Dequeue();
|
|
_peer.SendRawData(packet);
|
|
_peer.Recycle(packet);
|
|
}
|
|
}
|
|
return true;
|
|
}
|
|
}
|
|
}
|