1 write to _toProduceChannel
Microsoft.ML.Data (1)
Transforms\RowShufflingTransformer.cs (1)
545_toProduceChannel = Channel.CreateUnbounded<int>(new UnboundedChannelOptions { SingleWriter = true });
5 references to _toProduceChannel
Microsoft.ML.Data (5)
Transforms\RowShufflingTransformer.cs (5)
547PostAssert(_toProduceChannel, _poolRows - 1 + _blockSize); 550PostAssert(_toProduceChannel, _blockSize); 571while (await _toProduceChannel.Reader.WaitToReadAsync().ConfigureAwait(false)) 574if (!_toProduceChannel.Reader.TryRead(out requested)) 630PostAssert(_toProduceChannel, _deadCount);