_source | System.Threading.Tasks.Dataflow.BatchBlock< T > | private |
_target | System.Threading.Tasks.Dataflow.BatchBlock< T > | private |
BatchBlock(int batchSize) | System.Threading.Tasks.Dataflow.BatchBlock< T > | inline |
BatchBlock(int batchSize, GroupingDataflowBlockOptions dataflowBlockOptions) | System.Threading.Tasks.Dataflow.BatchBlock< T > | inline |
BatchSize | System.Threading.Tasks.Dataflow.BatchBlock< T > | |
Complete() | System.Threading.Tasks.Dataflow.BatchBlock< T > | inline |
Completion | System.Threading.Tasks.Dataflow.BatchBlock< T > | |
ConsumeMessage(DataflowMessageHeader messageHeader, ITargetBlock< T[]> target, out bool messageConsumed) | System.Threading.Tasks.Dataflow.BatchBlock< T > | inlineprivate |
ISourceBlock< T[]>.ConsumeMessage(DataflowMessageHeader messageHeader, ITargetBlock< TOutput > target, out bool messageConsumed) | System.Threading.Tasks.Dataflow.ISourceBlock< T[]> | |
Content | System.Threading.Tasks.Dataflow.BatchBlock< T > | private |
DebuggerDisplayContent | System.Threading.Tasks.Dataflow.BatchBlock< T > | private |
Fault(Exception exception) | System.Threading.Tasks.Dataflow.BatchBlock< T > | inlineprivate |
LinkTo(ITargetBlock< T[]> target, DataflowLinkOptions linkOptions) | System.Threading.Tasks.Dataflow.BatchBlock< T > | inline |
ISourceBlock< T[]>.LinkTo(ITargetBlock< TOutput > target, DataflowLinkOptions linkOptions) | System.Threading.Tasks.Dataflow.ISourceBlock< T[]> | |
OfferMessage(DataflowMessageHeader messageHeader, T messageValue, ISourceBlock< T > source, bool consumeToAccept) | System.Threading.Tasks.Dataflow.BatchBlock< T > | inlineprivate |
ITargetBlock< T >.OfferMessage(DataflowMessageHeader messageHeader, TInput messageValue, ISourceBlock< TInput >? source, bool consumeToAccept) | System.Threading.Tasks.Dataflow.ITargetBlock< T > | |
OutputCount | System.Threading.Tasks.Dataflow.BatchBlock< T > | |
OutputCountForDebugger | System.Threading.Tasks.Dataflow.BatchBlock< T > | private |
ReleaseReservation(DataflowMessageHeader messageHeader, ITargetBlock< T[]> target) | System.Threading.Tasks.Dataflow.BatchBlock< T > | inlineprivate |
ISourceBlock< T[]>.ReleaseReservation(DataflowMessageHeader messageHeader, ITargetBlock< TOutput > target) | System.Threading.Tasks.Dataflow.ISourceBlock< T[]> | |
ReserveMessage(DataflowMessageHeader messageHeader, ITargetBlock< T[]> target) | System.Threading.Tasks.Dataflow.BatchBlock< T > | inlineprivate |
ISourceBlock< T[]>.ReserveMessage(DataflowMessageHeader messageHeader, ITargetBlock< TOutput > target) | System.Threading.Tasks.Dataflow.ISourceBlock< T[]> | |
ToString() | System.Threading.Tasks.Dataflow.BatchBlock< T > | inline |
TriggerBatch() | System.Threading.Tasks.Dataflow.BatchBlock< T > | inline |
TryReceive(Predicate< T[]>? filter, [NotNullWhen(true)] out T[]? item) | System.Threading.Tasks.Dataflow.BatchBlock< T > | inline |
IReceivableSourceBlock< T[]>.TryReceive(Predicate< TOutput >? filter,[MaybeNullWhen(false)] out TOutput item) | System.Threading.Tasks.Dataflow.IReceivableSourceBlock< T[]> | |
TryReceiveAll([NotNullWhen(true)] out IList< T[]>? items) | System.Threading.Tasks.Dataflow.BatchBlock< T > | inline |
IReceivableSourceBlock< T[]>.TryReceiveAll([NotNullWhen(true)] out IList< TOutput >? items) | System.Threading.Tasks.Dataflow.IReceivableSourceBlock< T[]> | |