1 write to _toRead
Microsoft.ML.Data (1)
DataLoadSave\Binary\BinaryLoader.cs (1)
1576
_toRead
= new BlockingCollection<Block>(bufferSize);
4 references to _toRead
Microsoft.ML.Data (4)
DataLoadSave\Binary\BinaryLoader.cs (4)
1577
_toReadEnumerator =
_toRead
.GetConsumingEnumerable(ExMarshaller.Token).GetEnumerator();
1607
Ectx.Assert(!
_toRead
.IsAddingCompleted);
1611
_toRead
.CompleteAdding();
1624
_toRead
.Add(block, ExMarshaller.Token);