25 references to TransformManyBlock
System.Threading.Tasks.Dataflow (25)
Blocks\TransformManyBlock.cs (20)
23/// <typeparam name="TInput">Specifies the type of data received and operated on by this <see cref="TransformManyBlock{TInput,TOutput}"/>.</typeparam> 24/// <typeparam name="TOutput">Specifies the type of data output by this <see cref="TransformManyBlock{TInput,TOutput}"/>.</typeparam> 26[DebuggerTypeProxy(typeof(TransformManyBlock<,>.DebugView))] 49/// <summary>Initializes the <see cref="TransformManyBlock{TInput,TOutput}"/> with the specified function.</summary> 52/// will be made available as output from this <see cref="TransformManyBlock{TInput,TOutput}"/>. 60/// <summary>Initializes the <see cref="TransformManyBlock{TInput,TOutput}"/> with the specified function and <see cref="ExecutionDataflowBlockOptions"/>.</summary> 63/// will be made available as output from this <see cref="TransformManyBlock{TInput,TOutput}"/>. 65/// <param name="dataflowBlockOptions">The options with which to configure this <see cref="TransformManyBlock{TInput,TOutput}"/>.</param> 74/// <summary>Initializes the <see cref="TransformManyBlock{TInput,TOutput}"/> with the specified function.</summary> 77/// will be made available as output from this <see cref="TransformManyBlock{TInput,TOutput}"/>. 84/// <summary>Initializes the <see cref="TransformManyBlock{TInput,TOutput}"/> with the specified function and <see cref="ExecutionDataflowBlockOptions"/>.</summary> 87/// will be made available as output from this <see cref="TransformManyBlock{TInput,TOutput}"/>. 89/// <param name="dataflowBlockOptions">The options with which to configure this <see cref="TransformManyBlock{TInput,TOutput}"/>.</param> 115onItemsRemoved = static (owningSource, count) => ((TransformManyBlock<TInput, TOutput>)owningSource)._target.ChangeBoundingCount(-count); 120static owningSource => ((TransformManyBlock<TInput, TOutput>)owningSource)._target.Complete(exception: null, dropPendingMessages: true), 128this, static (source, messages) => ((TransformManyBlock<TInput, TOutput>)source)._source.AddMessages(messages)); 152var thisBlock = ((TransformManyBlock<TInput, TOutput>)state!) as IDataflowBlock; 242var tuple = (Tuple<TransformManyBlock<TInput, TOutput>, KeyValuePair<TInput, long>>)state!; 619private readonly TransformManyBlock<TInput, TOutput> _transformManyBlock; 627public DebugView(TransformManyBlock<TInput, TOutput> transformManyBlock)
Blocks\TransformManyBlock.IAsyncEnumerable.cs (5)
12/// <summary>Initializes the <see cref="TransformManyBlock{TInput,TOutput}"/> with the specified function.</summary> 15/// will be made available as output from this <see cref="TransformManyBlock{TInput,TOutput}"/>. 23/// <summary>Initializes the <see cref="TransformManyBlock{TInput,TOutput}"/> with the specified function and <see cref="ExecutionDataflowBlockOptions"/>.</summary> 26/// will be made available as output from this <see cref="TransformManyBlock{TInput,TOutput}"/>. 28/// <param name="dataflowBlockOptions">The options with which to configure this <see cref="TransformManyBlock{TInput,TOutput}"/>.</param>