internal class StringOutgoingMessage()

in src/Azure.AppService.Tunnel/Tunnel/WebSockets/Outgoing/StringOutgoingMessage.cs [9:21]


internal class StringOutgoingMessage(Lifetime lifetime, WebSocket webSocket, string message) : IOutgoingMessage
{
    public bool SilentFailure => false;

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

        await webSocket.SendAsync(new ArraySegment<byte>(Encoding.UTF8.GetBytes(message)),
            WebSocketMessageType.Text, true,
            lifetime);
    }
}