Code:
/ 4.0 / 4.0 / untmp / 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.
Link Menu

This book is available now!
Buy at Amazon US or
Buy at Amazon UK
- ProfilePropertySettingsCollection.cs
- DateTimeFormat.cs
- HttpListenerRequest.cs
- SubtreeProcessor.cs
- VisualStyleTypesAndProperties.cs
- ConfigUtil.cs
- RequiredFieldValidator.cs
- Themes.cs
- RotateTransform3D.cs
- QueryIntervalOp.cs
- PngBitmapEncoder.cs
- OleDbInfoMessageEvent.cs
- DmlSqlGenerator.cs
- ArrangedElementCollection.cs
- ActivityCodeDomSerializer.cs
- ExpressionPrefixAttribute.cs
- DataStreams.cs
- QuerySelectOp.cs
- TripleDESCryptoServiceProvider.cs
- TabControlEvent.cs
- HeaderLabel.cs
- UserInitiatedNavigationPermission.cs
- TargetPerspective.cs
- FloaterParagraph.cs
- NativeCompoundFileAPIs.cs
- AssociativeAggregationOperator.cs
- CellQuery.cs
- Vector3DCollectionValueSerializer.cs
- FrameworkElementAutomationPeer.cs
- InstanceDataCollectionCollection.cs
- OwnerDrawPropertyBag.cs
- IntegerCollectionEditor.cs
- TreeNodeBindingCollection.cs
- QilTargetType.cs
- EnvelopeVersion.cs
- RoleManagerModule.cs
- BamlStream.cs
- __Error.cs
- MemoryFailPoint.cs
- InkCanvas.cs
- TaskFileService.cs
- FontStretch.cs
- ISAPIRuntime.cs
- CalendarDay.cs
- SharedUtils.cs
- MissingManifestResourceException.cs
- Grammar.cs
- WS2007FederationHttpBinding.cs
- ScriptControlManager.cs
- UInt32.cs
- XmlAttributeOverrides.cs
- ZipIOCentralDirectoryFileHeader.cs
- Misc.cs
- SafeEventLogWriteHandle.cs
- WorkflowQueue.cs
- RequestCache.cs
- ImageBrush.cs
- NullReferenceException.cs
- PackageRelationshipCollection.cs
- PropertyInfo.cs
- PolicyManager.cs
- Exception.cs
- ComAdminWrapper.cs
- Rule.cs
- MimeParameters.cs
- CompressedStack.cs
- SourceInterpreter.cs
- Stylesheet.cs
- CodeMemberProperty.cs
- PerformanceCounterPermission.cs
- EncoderParameter.cs
- ResXResourceReader.cs
- OdbcConnectionString.cs
- MetadataReference.cs
- AppDomainProtocolHandler.cs
- SafeCryptoHandles.cs
- DataKeyCollection.cs
- PrimitiveType.cs
- Size.cs
- InternalEnumValidator.cs
- ConfigurationManagerInternal.cs
- Base64Decoder.cs
- VirtualPathUtility.cs
- SerializationInfoEnumerator.cs
- ObjRef.cs
- ListItemViewAttribute.cs
- SqlServices.cs
- CLSCompliantAttribute.cs
- DbConnectionStringCommon.cs
- IdentityNotMappedException.cs
- DocumentViewerBaseAutomationPeer.cs
- SchemaImporterExtensionElementCollection.cs
- XhtmlBasicListAdapter.cs
- AbstractSvcMapFileLoader.cs
- Parser.cs
- FilteredReadOnlyMetadataCollection.cs
- CreateParams.cs
- DataException.cs
- PriorityQueue.cs
- XMLUtil.cs