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
- ExpressionNormalizer.cs
- RectKeyFrameCollection.cs
- ExpressionNode.cs
- HttpHandlerActionCollection.cs
- ConfigurationElementCollection.cs
- CanonicalXml.cs
- DesignerSelectionListAdapter.cs
- MediaSystem.cs
- EdmFunctionAttribute.cs
- RepeatBehavior.cs
- Thread.cs
- PointValueSerializer.cs
- DesignerTextWriter.cs
- EmbossBitmapEffect.cs
- ChangeConflicts.cs
- BaseParaClient.cs
- XsdBuilder.cs
- SqlTrackingQuery.cs
- TextBlock.cs
- _LazyAsyncResult.cs
- ProfileModule.cs
- EnvironmentPermission.cs
- BufferedWebEventProvider.cs
- UnsafeNativeMethods.cs
- ThreadStaticAttribute.cs
- DBSqlParserColumnCollection.cs
- MimeMapping.cs
- ADRoleFactoryConfiguration.cs
- BitConverter.cs
- JsonDeserializer.cs
- Application.cs
- _ListenerAsyncResult.cs
- RootCodeDomSerializer.cs
- ThreadStateException.cs
- GACIdentityPermission.cs
- ListViewCancelEventArgs.cs
- ProcessModuleDesigner.cs
- CollectionBuilder.cs
- DynamicUpdateCommand.cs
- ClipboardData.cs
- XPathParser.cs
- SystemIPInterfaceStatistics.cs
- Inline.cs
- adornercollection.cs
- AxHost.cs
- FindCompletedEventArgs.cs
- DashStyle.cs
- DSASignatureFormatter.cs
- CodeConstructor.cs
- StyleCollection.cs
- Component.cs
- RuleInfoComparer.cs
- ObjectRef.cs
- QueryPageSettingsEventArgs.cs
- ImageAutomationPeer.cs
- ViewBase.cs
- ScrollProperties.cs
- DiscreteKeyFrames.cs
- DataGridViewRowEventArgs.cs
- OrderedDictionaryStateHelper.cs
- FieldDescriptor.cs
- Message.cs
- CheckBoxField.cs
- WorkflowApplicationUnhandledExceptionEventArgs.cs
- HttpContext.cs
- TextServicesCompartment.cs
- DiscardableAttribute.cs
- mansign.cs
- SafeMemoryMappedFileHandle.cs
- EntityDataSourceValidationException.cs
- mactripleDES.cs
- ValueChangedEventManager.cs
- WebBrowserUriTypeConverter.cs
- DataGridViewImageColumn.cs
- GroupItemAutomationPeer.cs
- PrintDialog.cs
- MessageHeaderDescriptionCollection.cs
- StringUtil.cs
- XmlDataSourceNodeDescriptor.cs
- ManagedFilter.cs
- ModuleBuilderData.cs
- GrammarBuilder.cs
- WindowsListViewItem.cs
- FieldBuilder.cs
- MemberMaps.cs
- DataGridColumnCollection.cs
- SrgsGrammarCompiler.cs
- SizeLimitedCache.cs
- ConfigurationValues.cs
- PixelShader.cs
- FileUpload.cs
- SqlParameterizer.cs
- LinqDataSource.cs
- ETagAttribute.cs
- OletxDependentTransaction.cs
- PopupControlService.cs
- DbExpressionRules.cs
- DisableDpiAwarenessAttribute.cs
- Int64AnimationBase.cs
- PrtCap_Reader.cs