ListQueryResults.cs source code in C# .NET

Source code for the .NET framework in C#

                        
Code:

                         / 4.0 / 4.0 / DEVDIV_TFS / Dev10 / Releases / RTMRel / ndp / fx / src / Core / System / Linq / Parallel / QueryOperators / ListQueryResults.cs / 1305376 / ListQueryResults.cs
                        

                        
                            // ==++== 
//
//   Copyright (c) Microsoft Corporation.  All rights reserved.
//
// ==--== 
// =+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+
// 
// ListQueryResults.cs 
//
// [....] 
//
// =-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-

using System.Collections.Generic; 

namespace System.Linq.Parallel 
{ 
    /// 
    /// Class to represent an IList{T} as QueryResults{T} 
    /// 
    /// 
    internal class ListQueryResults : QueryResults
    { 
        private IList m_source;
        private int m_partitionCount; 
        private bool m_useStriping; 

        internal ListQueryResults(IList source, int partitionCount, bool useStriping) 
        {
            m_source = source;
            m_partitionCount = partitionCount;
            m_useStriping = useStriping; 
        }
 
        internal override void GivePartitionedStream(IPartitionedStreamRecipient recipient) 
        {
            PartitionedStream partitionedStream = GetPartitionedStream(); 
            recipient.Receive(partitionedStream);
        }

        internal override bool IsIndexible 
        {
            get { return true; } 
        } 

        internal override int ElementsCount 
        {
            get { return m_source.Count; }
        }
 
        internal override T GetElement(int index)
        { 
            return m_source[index]; 
        }
 
        internal PartitionedStream GetPartitionedStream()
        {
            return ExchangeUtilities.PartitionDataSource(m_source, m_partitionCount, m_useStriping);
        } 
    }
} 

// File provided for Reference Use Only by Microsoft Corporation (c) 2007.
// ==++== 
//
//   Copyright (c) Microsoft Corporation.  All rights reserved.
//
// ==--== 
// =+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+
// 
// ListQueryResults.cs 
//
// [....] 
//
// =-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-

using System.Collections.Generic; 

namespace System.Linq.Parallel 
{ 
    /// 
    /// Class to represent an IList{T} as QueryResults{T} 
    /// 
    /// 
    internal class ListQueryResults : QueryResults
    { 
        private IList m_source;
        private int m_partitionCount; 
        private bool m_useStriping; 

        internal ListQueryResults(IList source, int partitionCount, bool useStriping) 
        {
            m_source = source;
            m_partitionCount = partitionCount;
            m_useStriping = useStriping; 
        }
 
        internal override void GivePartitionedStream(IPartitionedStreamRecipient recipient) 
        {
            PartitionedStream partitionedStream = GetPartitionedStream(); 
            recipient.Receive(partitionedStream);
        }

        internal override bool IsIndexible 
        {
            get { return true; } 
        } 

        internal override int ElementsCount 
        {
            get { return m_source.Count; }
        }
 
        internal override T GetElement(int index)
        { 
            return m_source[index]; 
        }
 
        internal PartitionedStream GetPartitionedStream()
        {
            return ExchangeUtilities.PartitionDataSource(m_source, m_partitionCount, m_useStriping);
        } 
    }
} 

// File provided for Reference Use Only by Microsoft Corporation (c) 2007.

Link Menu

Network programming in C#, Network Programming in VB.NET, Network Programming in .NET
This book is available now!
Buy at Amazon US or
Buy at Amazon UK