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

This book is available now!
Buy at Amazon US or
Buy at Amazon UK
- CorrelationActionMessageFilter.cs
- WebBrowserSiteBase.cs
- ISAPIWorkerRequest.cs
- X509CertificateTrustedIssuerElement.cs
- OleDbException.cs
- HtmlPhoneCallAdapter.cs
- DrawingAttributeSerializer.cs
- MobileComponentEditorPage.cs
- ToolTipService.cs
- AppDomainFactory.cs
- WebPartConnectionsCancelEventArgs.cs
- RelationshipFixer.cs
- FileFormatException.cs
- UInt16.cs
- SubqueryRules.cs
- SHA384Managed.cs
- TablePatternIdentifiers.cs
- FontConverter.cs
- QilInvoke.cs
- CodeSnippetExpression.cs
- LinqDataSourceDeleteEventArgs.cs
- StorageRoot.cs
- BoundColumn.cs
- TextInfo.cs
- CryptoApi.cs
- PackageDigitalSignature.cs
- SqlLiftWhereClauses.cs
- GifBitmapDecoder.cs
- ConnectionManagementElementCollection.cs
- EntityType.cs
- COSERVERINFO.cs
- InvalidStoreProtectionKeyException.cs
- WebPartDisplayModeCancelEventArgs.cs
- BamlResourceSerializer.cs
- DBConnection.cs
- Activity.cs
- PrintPreviewDialog.cs
- ObjectQuery_EntitySqlExtensions.cs
- EventLogPermissionAttribute.cs
- EnumerableCollectionView.cs
- GenericsInstances.cs
- SystemWebSectionGroup.cs
- ComboBox.cs
- ObjectStateFormatter.cs
- ListViewGroupConverter.cs
- QueryProcessor.cs
- DrawingImage.cs
- PointValueSerializer.cs
- DetailsViewPageEventArgs.cs
- TextPenaltyModule.cs
- PropertyConverter.cs
- ModelUIElement3D.cs
- DataGridRowDetailsEventArgs.cs
- BasePattern.cs
- TypeResolvingOptions.cs
- RtType.cs
- TrustManagerPromptUI.cs
- WorkflowStateRollbackService.cs
- SerialStream.cs
- XmlSchemaAnyAttribute.cs
- VersionedStreamOwner.cs
- HttpProfileBase.cs
- RedistVersionInfo.cs
- MailDefinition.cs
- RecognizedWordUnit.cs
- PageTheme.cs
- KeyFrames.cs
- TouchDevice.cs
- Stackframe.cs
- ReflectionPermission.cs
- XmlChoiceIdentifierAttribute.cs
- SqlProviderUtilities.cs
- coordinatorscratchpad.cs
- ExecutedRoutedEventArgs.cs
- MethodImplAttribute.cs
- Label.cs
- XmlDocumentType.cs
- AtomPub10CategoriesDocumentFormatter.cs
- SmtpFailedRecipientException.cs
- DocumentCollection.cs
- FrugalMap.cs
- TextFormatter.cs
- initElementDictionary.cs
- ThreadInterruptedException.cs
- ChannelSinkStacks.cs
- FloaterBaseParaClient.cs
- JoinSymbol.cs
- TransformDescriptor.cs
- InternalMappingException.cs
- CommunicationObjectAbortedException.cs
- ListViewSelectEventArgs.cs
- UnsafeNativeMethodsCLR.cs
- ProxySimple.cs
- WebRequest.cs
- ErrorStyle.cs
- ByteAnimation.cs
- EngineSiteSapi.cs
- FontCacheLogic.cs
- DataBinder.cs
- EDesignUtil.cs