Terraria v1.4.4.9
Terraria source code documentation
|
Public Member Functions | |
IEnumerator< TInputOutput > | GetEnumerator () |
Package Functions | |
TInputOutput[] | GetResultsAsArray () |
Static Package Functions | |
static MergeExecutor< TInputOutput > | Execute< TKey > (PartitionedStream< TInputOutput, TKey > partitions, bool ignoreOutput, ParallelMergeOptions options, TaskScheduler taskScheduler, bool isOrdered, CancellationState cancellationState, int queryId) |
static AsynchronousChannel< TInputOutput >[] | MakeAsynchronousChannels (int partitionCount, ParallelMergeOptions options, IntValueEvent consumerEvent, CancellationToken cancellationToken) |
static SynchronousChannel< TInputOutput >[] | MakeSynchronousChannels (int partitionCount) |
Private Member Functions | |
MergeExecutor () | |
void | Execute () |
IEnumerator IEnumerable. | GetEnumerator () |
Private Attributes | |
IMergeHelper< TInputOutput > | _mergeHelper |
Definition at line 8 of file MergeExecutor.cs.