internal class ByteOutgoingMessage()

in src/Azure.AppService.Tunnel/Tunnel/WebSockets/Outgoing/ByteOutgoingMessage.cs [8:19]


internal class ByteOutgoingMessage(Lifetime lifetime, WebSocket webSocket, byte[] message) : IOutgoingMessage
{
    public bool SilentFailure => false;

    public async Task Execute()
    {
        if (webSocket.GetState() != WebSocketState.Open) return;

        await webSocket.SendAsync(new ArraySegment<byte>(message), WebSocketMessageType.Binary, true,
            lifetime);
    }
}