1 write to _toRead
Microsoft.ML.Data (1)
DataLoadSave\Binary\BinaryLoader.cs (1)
1799
_toRead
= new BlockingCollection<ReaderContainer>(bufferSize);
4 references to _toRead
Microsoft.ML.Data (4)
DataLoadSave\Binary\BinaryLoader.cs (4)
1800
_toReadEnumerator =
_toRead
.GetConsumingEnumerable(ExMarshaller.Token).GetEnumerator();
1862
Contracts.Assert(!
_toRead
.IsAddingCompleted);
1868
_toRead
.CompleteAdding();
1902
_toRead
.Add(new ReaderContainer(reader, decomp, block.Rows, block.BlockSequence), ExMarshaller.Token);