Files
NezhaAgentHTTPBridge/WebApplication4/Services/WebSocketMessageStore.cs
2025-09-21 16:38:23 +08:00

30 lines
722 B
C#

using System;
using System.Threading;
namespace WebApplication4.Services
{
public class WebSocketMessageStore
{
private string? _lastMessage;
private DateTime? _receivedAtUtc;
private readonly object _lock = new();
public void Set(string message)
{
if (message == null) return;
lock (_lock)
{
_lastMessage = message;
_receivedAtUtc = DateTime.UtcNow;
}
}
public (string? Message, DateTime? ReceivedAtUtc) Get()
{
lock (_lock)
{
return (_lastMessage, _receivedAtUtc);
}
}
}
}