DataLoadSave\Binary\BinaryLoader.cs (16)
1574_toDecompressEnumerator = _toDecompress.GetConsumingEnumerable(ExMarshaller.Token).GetEnumerator();
1577_toReadEnumerator = _toRead.GetConsumingEnumerable(ExMarshaller.Token).GetEnumerator();
1587_toDecompress.Add(block, ExMarshaller.Token);
1593_toDecompress.Add(sentBlock, ExMarshaller.Token);
1610_waiter.Wait(block.BlockSequence, ExMarshaller.Token);
1618_waiter.Wait(block.BlockSequence, ExMarshaller.Token);
1623_waiter.Wait(block.BlockSequence, ExMarshaller.Token);
1624_toRead.Add(block, ExMarshaller.Token);
1798_toDecompressEnumerator = _toDecompress.GetConsumingEnumerable(ExMarshaller.Token).GetEnumerator();
1800_toReadEnumerator = _toRead.GetConsumingEnumerable(ExMarshaller.Token).GetEnumerator();
1821_toDecompress.Add(block, ExMarshaller.Token);
1827_toDecompress.Add(sentBlock, ExMarshaller.Token);
1867_waiter.Wait(block.BlockSequence, ExMarshaller.Token);
1882_waiter.Wait(block.BlockSequence, ExMarshaller.Token);
1900_waiter.Wait(block.BlockSequence, ExMarshaller.Token);
1902_toRead.Add(new ReaderContainer(reader, decomp, block.Rows, block.BlockSequence), ExMarshaller.Token);