Skip to content

Commit

Permalink
Add SingleReader to true on InChannel since only one consumer is read…
Browse files Browse the repository at this point in the history
…ing from it (#87)
  • Loading branch information
Mpdreamz authored Feb 11, 2025
1 parent 14de339 commit d30c5e7
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion src/Elastic.Channels/BufferedChannelBase.cs
Original file line number Diff line number Diff line change
Expand Up @@ -182,7 +182,7 @@ protected BufferedChannelBase(TChannelOptions options, ICollection<IChannelCallb
};
InChannel = Channel.CreateBounded<TEvent?>(new BoundedChannelOptions(maxIn)
{
SingleReader = false,
SingleReader = true,
SingleWriter = false,
// Stephen Toub comment: https://github.com/dotnet/runtime/issues/26338#issuecomment-393720727
// AFAICT this is fine since we run in a dedicated long running task.
Expand Down

0 comments on commit d30c5e7

Please sign in to comment.