1 write to _toConsumeChannel
Microsoft.ML.Data (1)
Transforms\RowShufflingTransformer.cs (1)
544_toConsumeChannel = Channel.CreateUnbounded<int>(new UnboundedChannelOptions { SingleWriter = true });
4 references to _toConsumeChannel
Microsoft.ML.Data (4)
Transforms\RowShufflingTransformer.cs (4)
596PostAssert(_toConsumeChannel, numRows); 603PostAssert(_toConsumeChannel, 0); 612PostAssert(_toConsumeChannel, 0); 637ValueTask<int> readTask = _toConsumeChannel.Reader.ReadAsync();