1 write to _toDecompress
Microsoft.ML.Data (1)
DataLoadSave\Binary\BinaryLoader.cs (1)
1570
_toDecompress
= new BlockingCollection<Block>(_bufferSize);
4 references to _toDecompress
Microsoft.ML.Data (4)
DataLoadSave\Binary\BinaryLoader.cs (4)
1574
_toDecompressEnumerator =
_toDecompress
.GetConsumingEnumerable(ExMarshaller.Token).GetEnumerator();
1587
_toDecompress
.Add(block, ExMarshaller.Token);
1593
_toDecompress
.Add(sentBlock, ExMarshaller.Token);
1594
_toDecompress
.CompleteAdding();