14 lines
385 B
C#
14 lines
385 B
C#
|
using System.Threading.Channels;
|
||
|
|
|
||
|
|
namespace PlanTempus.Core.Telemetry;
|
||
|
|
|
||
|
|
public class NotificationChannel : IMessageChannel<string>
|
||
|
|
{
|
||
|
|
private readonly Channel<string> _channel = Channel.CreateUnbounded<string>();
|
||
|
|
|
||
|
|
public ChannelWriter<string> Writer => _channel.Writer;
|
||
|
|
public ChannelReader<string> Reader => _channel.Reader;
|
||
|
|
|
||
|
|
public void Dispose() => _channel.Writer.Complete();
|
||
|
|
}
|