public sealed class VisitMetadataChannel
{
private readonly Channel<VisitMetadata> _channel = Channel.CreateUnbounded<VisitMetadata>(
new UnboundedChannelOptions
{
SingleReader = true,
SingleWriter = false,
AllowSynchronousContinuations = false
});
public ChannelWriter<VisitMetadata> Writer => _channel.Writer;
public ChannelReader<VisitMetadata> Reader => _channel.Reader;
}
public sealed class VisitMetadataChannel
{
private readonly Channel<VisitMetadata> _channel = Channel.CreateUnbounded<VisitMetadata>(
new UnboundedChannelOptions
{
SingleReader = true,
SingleWriter = false,
AllowSynchronousContinuations = false
});
public ChannelWriter<VisitMetadata> Writer => _channel.Writer;
public ChannelReader<VisitMetadata> Reader => _channel.Reader;
}