Code:
/ 4.0 / 4.0 / untmp / DEVDIV_TFS / Dev10 / Releases / RTMRel / ndp / fx / src / Core / System / Linq / Parallel / QueryOperators / ListQueryResults.cs / 1305376 / ListQueryResults.cs
// ==++== // // Copyright (c) Microsoft Corporation. All rights reserved. // // ==--== // =+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+ // // ListQueryResults.cs // //[....] // // =-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=- using System.Collections.Generic; namespace System.Linq.Parallel { ////// Class to represent an IList{T} as QueryResults{T} /// ///internal class ListQueryResults : QueryResults { private IList m_source; private int m_partitionCount; private bool m_useStriping; internal ListQueryResults(IList source, int partitionCount, bool useStriping) { m_source = source; m_partitionCount = partitionCount; m_useStriping = useStriping; } internal override void GivePartitionedStream(IPartitionedStreamRecipient recipient) { PartitionedStream partitionedStream = GetPartitionedStream(); recipient.Receive (partitionedStream); } internal override bool IsIndexible { get { return true; } } internal override int ElementsCount { get { return m_source.Count; } } internal override T GetElement(int index) { return m_source[index]; } internal PartitionedStream GetPartitionedStream() { return ExchangeUtilities.PartitionDataSource(m_source, m_partitionCount, m_useStriping); } } } // 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
- ConnectionInterfaceCollection.cs
- InheritanceContextChangedEventManager.cs
- SimpleHandlerFactory.cs
- BinaryParser.cs
- MimeFormImporter.cs
- OperationInvokerBehavior.cs
- MasterPageParser.cs
- WSHttpBindingBaseElement.cs
- ValidationResult.cs
- IgnoreFileBuildProvider.cs
- CharAnimationUsingKeyFrames.cs
- CacheVirtualItemsEvent.cs
- StylusEventArgs.cs
- DirtyTextRange.cs
- MailAddress.cs
- XmlDeclaration.cs
- NativeMethods.cs
- Rfc2898DeriveBytes.cs
- BitFlagsGenerator.cs
- ExecutionContext.cs
- TreeNodeBindingCollection.cs
- FreezableOperations.cs
- Point.cs
- TraceFilter.cs
- ForEachAction.cs
- ObjectListCommandsPage.cs
- PropertyItem.cs
- RuntimeArgument.cs
- AnnotationResource.cs
- ToolStripItemTextRenderEventArgs.cs
- UDPClient.cs
- ImageSource.cs
- SynchronizingStream.cs
- SpellerInterop.cs
- LoaderAllocator.cs
- SectionVisual.cs
- diagnosticsswitches.cs
- ConfigXmlComment.cs
- XmlDocumentFragment.cs
- DataGridPagerStyle.cs
- ColumnCollection.cs
- BufferBuilder.cs
- EncryptedXml.cs
- TouchFrameEventArgs.cs
- InheritanceContextHelper.cs
- MappingException.cs
- HMACSHA512.cs
- SQLSingle.cs
- WebPartZoneBaseDesigner.cs
- PathFigure.cs
- PerspectiveCamera.cs
- HostedTransportConfigurationBase.cs
- MachineKey.cs
- Cursor.cs
- BitmapScalingModeValidation.cs
- sqlmetadatafactory.cs
- CheckBoxFlatAdapter.cs
- UserControlParser.cs
- BaseParser.cs
- SerializationSectionGroup.cs
- DbProviderConfigurationHandler.cs
- SortAction.cs
- RoutedUICommand.cs
- PlainXmlSerializer.cs
- SplitContainer.cs
- ToolStripTextBox.cs
- CardSpacePolicyElement.cs
- AuthorizationRuleCollection.cs
- NativeMethods.cs
- CqlLexer.cs
- SecurityPolicySection.cs
- UiaCoreApi.cs
- Tuple.cs
- DispatcherExceptionFilterEventArgs.cs
- CodeTypeParameter.cs
- ExceptionWrapper.cs
- XmlAttributeAttribute.cs
- MimePart.cs
- AttributeSetAction.cs
- MappedMetaModel.cs
- InvokeMethodActivityDesigner.cs
- VectorCollectionValueSerializer.cs
- _Rfc2616CacheValidators.cs
- XmlAttributeOverrides.cs
- ApplicationSecurityManager.cs
- TextDecorationLocationValidation.cs
- MsmqIntegrationBinding.cs
- FrameworkContentElement.cs
- ConstructorBuilder.cs
- UniqueIdentifierService.cs
- InkPresenter.cs
- RangeValidator.cs
- BinHexEncoder.cs
- SystemSounds.cs
- entityreference_tresulttype.cs
- ProfilePropertyMetadata.cs
- SoapInteropTypes.cs
- NotImplementedException.cs
- CopyOfAction.cs
- HttpCacheParams.cs