1 write to _toDecompress
Microsoft.ML.Data (1)
DataLoadSave\Binary\BinaryLoader.cs (1)
1797
_toDecompress
= new BlockingCollection<CompressedBlock>(_bufferSize);
5 references to _toDecompress
Microsoft.ML.Data (5)
DataLoadSave\Binary\BinaryLoader.cs (5)
1474
/// <see cref="ReadPipe{T}.
_toDecompress
"/> queue. This returns true if and only if it
1798
_toDecompressEnumerator =
_toDecompress
.GetConsumingEnumerable(ExMarshaller.Token).GetEnumerator();
1821
_toDecompress
.Add(block, ExMarshaller.Token);
1827
_toDecompress
.Add(sentBlock, ExMarshaller.Token);
1828
_toDecompress
.CompleteAdding();