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
- EasingKeyFrames.cs
- COSERVERINFO.cs
- TextRunTypographyProperties.cs
- RSAPKCS1SignatureFormatter.cs
- InputGestureCollection.cs
- WebPermission.cs
- SqlMetaData.cs
- MultiView.cs
- CodeEntryPointMethod.cs
- ApplicationHost.cs
- PageBuildProvider.cs
- CallbackDebugElement.cs
- SmtpCommands.cs
- BaseValidator.cs
- externdll.cs
- StateMachineDesignerPaint.cs
- CachedRequestParams.cs
- InfoCardRSAPKCS1KeyExchangeFormatter.cs
- OleDbConnectionFactory.cs
- SafePEFileHandle.cs
- SchemaSetCompiler.cs
- ControlPropertyNameConverter.cs
- FileLogRecordHeader.cs
- PowerModeChangedEventArgs.cs
- FrameDimension.cs
- TableLayoutPanelBehavior.cs
- _ProxyRegBlob.cs
- EventTrigger.cs
- URI.cs
- ModuleElement.cs
- DbParameterHelper.cs
- DataControlField.cs
- DbConnectionStringCommon.cs
- CodeValidator.cs
- ActivityDesignerAccessibleObject.cs
- SymbolEqualComparer.cs
- OperandQuery.cs
- AncestorChangedEventArgs.cs
- TrackBar.cs
- Transform3DGroup.cs
- TraceData.cs
- EntityDataSourceSelectedEventArgs.cs
- CaseDesigner.xaml.cs
- ObjectTokenCategory.cs
- RepeatButtonAutomationPeer.cs
- DoubleLink.cs
- ControlCollection.cs
- CompilerCollection.cs
- BaseDataListActionList.cs
- WebPartAuthorizationEventArgs.cs
- ObjectTypeMapping.cs
- ServiceHostFactory.cs
- WebBrowsableAttribute.cs
- Parser.cs
- Nullable.cs
- MsdtcWrapper.cs
- XmlFileEditor.cs
- _CookieModule.cs
- Viewport3DAutomationPeer.cs
- TemplateBuilder.cs
- FixedPageAutomationPeer.cs
- EntityDataSourceConfigureObjectContext.cs
- FileRecordSequence.cs
- DigestComparer.cs
- DocumentSchemaValidator.cs
- HierarchicalDataSourceControl.cs
- SHA256.cs
- AlphaSortedEnumConverter.cs
- MappingSource.cs
- BadImageFormatException.cs
- __ComObject.cs
- XsltLibrary.cs
- SpecularMaterial.cs
- GlyphInfoList.cs
- CodeDomLoader.cs
- RepeaterItem.cs
- SoapTransportImporter.cs
- HostedElements.cs
- ResourceReader.cs
- CustomTypeDescriptor.cs
- ColumnTypeConverter.cs
- OneToOneMappingSerializer.cs
- DbDataRecord.cs
- CounterSampleCalculator.cs
- EmbeddedMailObjectsCollection.cs
- FloaterBaseParagraph.cs
- InstanceDataCollection.cs
- DataControlLinkButton.cs
- XPathEmptyIterator.cs
- X509IssuerSerialKeyIdentifierClause.cs
- DiagnosticsConfigurationHandler.cs
- Math.cs
- PathSegment.cs
- DoubleMinMaxAggregationOperator.cs
- DetailsViewPageEventArgs.cs
- CursorConverter.cs
- SqlDataSourceQueryEditor.cs
- QilXmlReader.cs
- SHA1Managed.cs
- BamlVersionHeader.cs