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();