_reorderingBuffer | System.Threading.Tasks.Dataflow.TransformManyBlock< TInput, TOutput > | private |
_source | System.Threading.Tasks.Dataflow.TransformManyBlock< TInput, TOutput > | private |
_target | System.Threading.Tasks.Dataflow.TransformManyBlock< TInput, TOutput > | private |
AsyncCompleteProcessMessageWithTask(Task< IEnumerable< TOutput > > completed, KeyValuePair< TInput, long > messageWithId) | System.Threading.Tasks.Dataflow.TransformManyBlock< TInput, TOutput > | inlineprivate |
Complete() | System.Threading.Tasks.Dataflow.TransformManyBlock< TInput, TOutput > | inline |
Completion | System.Threading.Tasks.Dataflow.TransformManyBlock< TInput, TOutput > | |
ConsumeMessage(DataflowMessageHeader messageHeader, ITargetBlock< TOutput > target, out bool messageConsumed) | System.Threading.Tasks.Dataflow.TransformManyBlock< TInput, TOutput > | inlineprivate |
Content | System.Threading.Tasks.Dataflow.TransformManyBlock< TInput, TOutput > | private |
DebuggerDisplayContent | System.Threading.Tasks.Dataflow.TransformManyBlock< TInput, TOutput > | private |
Fault(Exception exception) | System.Threading.Tasks.Dataflow.TransformManyBlock< TInput, TOutput > | inlineprivate |
InputCount | System.Threading.Tasks.Dataflow.TransformManyBlock< TInput, TOutput > | |
InputCountForDebugger | System.Threading.Tasks.Dataflow.TransformManyBlock< TInput, TOutput > | private |
LinkTo(ITargetBlock< TOutput > target, DataflowLinkOptions linkOptions) | System.Threading.Tasks.Dataflow.TransformManyBlock< TInput, TOutput > | inline |
OfferMessage(DataflowMessageHeader messageHeader, TInput messageValue, ISourceBlock< TInput > source, bool consumeToAccept) | System.Threading.Tasks.Dataflow.TransformManyBlock< TInput, TOutput > | inlineprivate |
ITargetBlock< TInput >.OfferMessage(DataflowMessageHeader messageHeader, TInput messageValue, ISourceBlock< TInput >? source, bool consumeToAccept) | System.Threading.Tasks.Dataflow.ITargetBlock< TInput > | |
OutputCount | System.Threading.Tasks.Dataflow.TransformManyBlock< TInput, TOutput > | |
OutputCountForDebugger | System.Threading.Tasks.Dataflow.TransformManyBlock< TInput, TOutput > | private |
ParallelSourceLock | System.Threading.Tasks.Dataflow.TransformManyBlock< TInput, TOutput > | private |
ProcessMessage(Func< TInput, IEnumerable< TOutput > > transformFunction, KeyValuePair< TInput, long > messageWithId) | System.Threading.Tasks.Dataflow.TransformManyBlock< TInput, TOutput > | inlineprivate |
ProcessMessageWithTask(Func< TInput, Task< IEnumerable< TOutput > > > function, KeyValuePair< TInput, long > messageWithId) | System.Threading.Tasks.Dataflow.TransformManyBlock< TInput, TOutput > | inlineprivate |
ReleaseReservation(DataflowMessageHeader messageHeader, ITargetBlock< TOutput > target) | System.Threading.Tasks.Dataflow.TransformManyBlock< TInput, TOutput > | inlineprivate |
ReserveMessage(DataflowMessageHeader messageHeader, ITargetBlock< TOutput > target) | System.Threading.Tasks.Dataflow.TransformManyBlock< TInput, TOutput > | inlineprivate |
StoreOutputItems(KeyValuePair< TInput, long > messageWithId, IEnumerable< TOutput > outputItems) | System.Threading.Tasks.Dataflow.TransformManyBlock< TInput, TOutput > | inlineprivate |
StoreOutputItemsNonReorderedAtomic(IEnumerable< TOutput > outputItems) | System.Threading.Tasks.Dataflow.TransformManyBlock< TInput, TOutput > | inlineprivate |
StoreOutputItemsNonReorderedWithIteration(IEnumerable< TOutput > outputItems) | System.Threading.Tasks.Dataflow.TransformManyBlock< TInput, TOutput > | inlineprivate |
StoreOutputItemsReordered(long id, IEnumerable< TOutput > item) | System.Threading.Tasks.Dataflow.TransformManyBlock< TInput, TOutput > | inlineprivate |
ToString() | System.Threading.Tasks.Dataflow.TransformManyBlock< TInput, TOutput > | inline |
TransformManyBlock(Func< TInput, IEnumerable< TOutput > > transform) | System.Threading.Tasks.Dataflow.TransformManyBlock< TInput, TOutput > | inline |
TransformManyBlock(Func< TInput, IEnumerable< TOutput > > transform, ExecutionDataflowBlockOptions dataflowBlockOptions) | System.Threading.Tasks.Dataflow.TransformManyBlock< TInput, TOutput > | inline |
TransformManyBlock(Func< TInput, Task< IEnumerable< TOutput > > > transform) | System.Threading.Tasks.Dataflow.TransformManyBlock< TInput, TOutput > | inline |
TransformManyBlock(Func< TInput, Task< IEnumerable< TOutput > > > transform, ExecutionDataflowBlockOptions dataflowBlockOptions) | System.Threading.Tasks.Dataflow.TransformManyBlock< TInput, TOutput > | inline |
TransformManyBlock(Func< TInput, IEnumerable< TOutput > > transformSync, Func< TInput, Task< IEnumerable< TOutput > > > transformAsync, ExecutionDataflowBlockOptions dataflowBlockOptions) | System.Threading.Tasks.Dataflow.TransformManyBlock< TInput, TOutput > | inlineprivate |
TryReceive(Predicate< TOutput >? filter, [MaybeNullWhen(false)] out TOutput item) | System.Threading.Tasks.Dataflow.TransformManyBlock< TInput, TOutput > | inline |
TryReceiveAll([NotNullWhen(true)] out IList< TOutput >? items) | System.Threading.Tasks.Dataflow.TransformManyBlock< TInput, TOutput > | inline |
UpdateBoundingCountWithOutputCount(int count) | System.Threading.Tasks.Dataflow.TransformManyBlock< TInput, TOutput > | inlineprivate |