Code:
/ 4.0 / 4.0 / DEVDIV_TFS / Dev10 / Releases / RTMRel / ndp / fx / src / Core / System / Linq / Parallel / QueryOperators / QueryResults.cs / 1305376 / QueryResults.cs
// ==++== // // Copyright (c) Microsoft Corporation. All rights reserved. // // ==--== // =+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+ // // QueryResults.cs // //[....] // // =-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=- using System.Collections; using System.Collections.Generic; using System.Diagnostics.Contracts; namespace System.Linq.Parallel { ////// The QueryResults{T} is a class representing the results of the query. There may /// be different ways the query results can be manipulated. Currently, two ways are /// supported: /// /// 1. Open the query results as a partitioned stream by calling GivePartitionedStream /// and pass a generic action as an argument. /// /// 2. Access individual elements of the results list by calling GetElement(index) and /// ElementsCount. This method of accessing the query results is available only if /// IsIndexible return true. /// ///internal abstract class QueryResults : IList { //------------------------------------------------------------------------------------ // Gets the query results represented as a partitioned stream. Instead of returning // the PartitionedStream, we instead call recipient.Receive (...). That way, // the code that receives the partitioned stream has access to the TKey type. // // Arguments: // recipient - the object that the partitioned stream will be passed to // internal abstract void GivePartitionedStream(IPartitionedStreamRecipient recipient); //----------------------------------------------------------------------------------- // Returns whether the query results are indexible. If this property is true, the // user can call GetElement(index) and ElementsCount. If it is false, both // GetElement(index) and ElementsCount should throw InvalidOperationException. // internal virtual bool IsIndexible { get { return false; } } //----------------------------------------------------------------------------------- // Returns index-th element in the query results // // Assumptions: // IsIndexible returns true // 0 <= index < ElementsCount // internal virtual T GetElement(int index) { Contract.Assert(false, "GetElement property is not supported by non-indexible query results"); throw new NotSupportedException(); } //----------------------------------------------------------------------------------- // Returns the number of elements in the query results // // Assumptions: // IsIndexible returns true // internal virtual int ElementsCount { get { Contract.Assert(false, "ElementsCount property is not supported by non-indexible query results"); throw new NotSupportedException(); } } // // An assortment of methods we need to support in order to implement the IList interface // int IList .IndexOf(T item) { throw new NotSupportedException(); } void IList .Insert(int index, T item) { throw new NotSupportedException(); } void IList .RemoveAt(int index) { throw new NotSupportedException(); } public T this[int index] { get { return GetElement(index); } set { throw new NotSupportedException(); } } void ICollection .Add(T item) { throw new NotSupportedException(); } void ICollection .Clear() { throw new NotSupportedException(); } bool ICollection .Contains(T item) { throw new NotSupportedException(); } void ICollection .CopyTo(T[] array, int arrayIndex) { throw new NotSupportedException(); } public int Count { get { return ElementsCount; } } bool ICollection .IsReadOnly { get { return true; } } bool ICollection .Remove(T item) { throw new NotSupportedException(); } IEnumerator IEnumerable .GetEnumerator() { for (int index = 0; index < Count; index++) { yield return this[index]; } } IEnumerator IEnumerable.GetEnumerator() { return ((IEnumerable )this).GetEnumerator(); } } } // File provided for Reference Use Only by Microsoft Corporation (c) 2007. // ==++== // // Copyright (c) Microsoft Corporation. All rights reserved. // // ==--== // =+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+ // // QueryResults.cs // // [....] // // =-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=- using System.Collections; using System.Collections.Generic; using System.Diagnostics.Contracts; namespace System.Linq.Parallel { ////// The QueryResults{T} is a class representing the results of the query. There may /// be different ways the query results can be manipulated. Currently, two ways are /// supported: /// /// 1. Open the query results as a partitioned stream by calling GivePartitionedStream /// and pass a generic action as an argument. /// /// 2. Access individual elements of the results list by calling GetElement(index) and /// ElementsCount. This method of accessing the query results is available only if /// IsIndexible return true. /// ///internal abstract class QueryResults : IList { //------------------------------------------------------------------------------------ // Gets the query results represented as a partitioned stream. Instead of returning // the PartitionedStream, we instead call recipient.Receive (...). That way, // the code that receives the partitioned stream has access to the TKey type. // // Arguments: // recipient - the object that the partitioned stream will be passed to // internal abstract void GivePartitionedStream(IPartitionedStreamRecipient recipient); //----------------------------------------------------------------------------------- // Returns whether the query results are indexible. If this property is true, the // user can call GetElement(index) and ElementsCount. If it is false, both // GetElement(index) and ElementsCount should throw InvalidOperationException. // internal virtual bool IsIndexible { get { return false; } } //----------------------------------------------------------------------------------- // Returns index-th element in the query results // // Assumptions: // IsIndexible returns true // 0 <= index < ElementsCount // internal virtual T GetElement(int index) { Contract.Assert(false, "GetElement property is not supported by non-indexible query results"); throw new NotSupportedException(); } //----------------------------------------------------------------------------------- // Returns the number of elements in the query results // // Assumptions: // IsIndexible returns true // internal virtual int ElementsCount { get { Contract.Assert(false, "ElementsCount property is not supported by non-indexible query results"); throw new NotSupportedException(); } } // // An assortment of methods we need to support in order to implement the IList interface // int IList .IndexOf(T item) { throw new NotSupportedException(); } void IList .Insert(int index, T item) { throw new NotSupportedException(); } void IList .RemoveAt(int index) { throw new NotSupportedException(); } public T this[int index] { get { return GetElement(index); } set { throw new NotSupportedException(); } } void ICollection .Add(T item) { throw new NotSupportedException(); } void ICollection .Clear() { throw new NotSupportedException(); } bool ICollection .Contains(T item) { throw new NotSupportedException(); } void ICollection .CopyTo(T[] array, int arrayIndex) { throw new NotSupportedException(); } public int Count { get { return ElementsCount; } } bool ICollection .IsReadOnly { get { return true; } } bool ICollection .Remove(T item) { throw new NotSupportedException(); } IEnumerator IEnumerable .GetEnumerator() { for (int index = 0; index < Count; index++) { yield return this[index]; } } IEnumerator IEnumerable.GetEnumerator() { return ((IEnumerable )this).GetEnumerator(); } } } // 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](/images/book.jpg)
This book is available now!
Buy at Amazon US or
Buy at Amazon UK
- ImageSourceConverter.cs
- AssemblyBuilder.cs
- XmlEncodedRawTextWriter.cs
- AutoGeneratedField.cs
- XmlSerializerSection.cs
- RequestCacheManager.cs
- DataSourceConverter.cs
- DecimalKeyFrameCollection.cs
- RenderData.cs
- TreeViewAutomationPeer.cs
- ColumnClickEvent.cs
- __Filters.cs
- FormViewUpdateEventArgs.cs
- DataView.cs
- Monitor.cs
- SqlCacheDependencyDatabaseCollection.cs
- ActivityExecutionFilter.cs
- XmlILTrace.cs
- ResXDataNode.cs
- DataGridViewComboBoxColumn.cs
- SqlUtils.cs
- IConvertible.cs
- ThaiBuddhistCalendar.cs
- AddingNewEventArgs.cs
- VerticalConnector.xaml.cs
- SvcFileManager.cs
- ScriptMethodAttribute.cs
- DragDrop.cs
- ImageSourceConverter.cs
- RSACryptoServiceProvider.cs
- SearchForVirtualItemEventArgs.cs
- GridItem.cs
- DigestTraceRecordHelper.cs
- XmlEncoding.cs
- ControlCommandSet.cs
- Button.cs
- DisposableCollectionWrapper.cs
- MessageFilterTable.cs
- ScriptingSectionGroup.cs
- LicenseProviderAttribute.cs
- InputScope.cs
- XmlRootAttribute.cs
- _ContextAwareResult.cs
- Conditional.cs
- ReadOnlyAttribute.cs
- PieceDirectory.cs
- GroupAggregateExpr.cs
- SqlNodeTypeOperators.cs
- PageAdapter.cs
- OleTxTransactionInfo.cs
- TCEAdapterGenerator.cs
- DataServiceRequest.cs
- ItemContainerGenerator.cs
- BinaryUtilClasses.cs
- IndentedWriter.cs
- ExpanderAutomationPeer.cs
- Selector.cs
- DBProviderConfigurationHandler.cs
- SqlBulkCopy.cs
- DiscoveryOperationContext.cs
- EditorZone.cs
- HttpContext.cs
- TrustSection.cs
- DefaultValueConverter.cs
- ScrollPatternIdentifiers.cs
- ProcessInfo.cs
- KoreanLunisolarCalendar.cs
- SemaphoreSecurity.cs
- MarkupProperty.cs
- LinqDataSourceInsertEventArgs.cs
- ElementsClipboardData.cs
- RequestSecurityToken.cs
- TemplatedWizardStep.cs
- TextProviderWrapper.cs
- Matrix3DValueSerializer.cs
- Maps.cs
- DataGridViewDataErrorEventArgs.cs
- WriteTimeStream.cs
- BulletedListEventArgs.cs
- KeyedCollection.cs
- XmlQuerySequence.cs
- RijndaelCryptoServiceProvider.cs
- SerialReceived.cs
- HttpModuleActionCollection.cs
- Attribute.cs
- TabItemWrapperAutomationPeer.cs
- ArithmeticException.cs
- TypeLibConverter.cs
- EncodedStreamFactory.cs
- ProfileParameter.cs
- HybridDictionary.cs
- DeferredTextReference.cs
- EUCJPEncoding.cs
- DataGridState.cs
- DataObject.cs
- HierarchicalDataBoundControl.cs
- Message.cs
- FunctionUpdateCommand.cs
- OptimalBreakSession.cs
- Filter.cs