using System.Net.WebSockets; using System.Threading.Channels; namespace LarpixVoice; public class Session { public WebSocket Socket { get; } public Channel<(byte[] Buffer, int Length)> SendQueue { get; } public Session(WebSocket socket) { Socket = socket; SendQueue = Channel.CreateBounded<(byte[] Buffer, int Length)>(new BoundedChannelOptions(256) { FullMode = BoundedChannelFullMode.Wait }); } }