11 implementations of IReceivableSourceBlock
System.Threading.Tasks.Dataflow (11)
Base\DataflowBlock.cs (1)
1560
private sealed class EncapsulatingPropagator<TInput, TOutput> : IPropagatorBlock<TInput, TOutput>,
IReceivableSourceBlock
<TOutput>, IDebuggerDisplay
Blocks\BatchBlock.cs (1)
26
public sealed class BatchBlock<T> : IPropagatorBlock<T, T[]>,
IReceivableSourceBlock
<T[]>, IDebuggerDisplay
Blocks\BatchedJoinBlock.cs (2)
29
public sealed class BatchedJoinBlock<T1, T2> :
IReceivableSourceBlock
<Tuple<IList<T1>, IList<T2>>>, IDebuggerDisplay
275
public sealed class BatchedJoinBlock<T1, T2, T3> :
IReceivableSourceBlock
<Tuple<IList<T1>, IList<T2>, IList<T3>>>, IDebuggerDisplay
Blocks\BroadcastBlock.cs (1)
36
public sealed class BroadcastBlock<T> : IPropagatorBlock<T, T>,
IReceivableSourceBlock
<T>, IDebuggerDisplay
Blocks\BufferBlock.cs (1)
25
public sealed class BufferBlock<T> : IPropagatorBlock<T, T>,
IReceivableSourceBlock
<T>, IDebuggerDisplay
Blocks\JoinBlock.cs (2)
31
public sealed class JoinBlock<T1, T2> :
IReceivableSourceBlock
<Tuple<T1, T2>>, IDebuggerDisplay
256
public sealed class JoinBlock<T1, T2, T3> :
IReceivableSourceBlock
<Tuple<T1, T2, T3>>, IDebuggerDisplay
Blocks\TransformBlock.cs (1)
25
public sealed class TransformBlock<TInput, TOutput> : IPropagatorBlock<TInput, TOutput>,
IReceivableSourceBlock
<TOutput>, IDebuggerDisplay
Blocks\TransformManyBlock.cs (1)
27
public sealed partial class TransformManyBlock<TInput, TOutput> : IPropagatorBlock<TInput, TOutput>,
IReceivableSourceBlock
<TOutput>, IDebuggerDisplay
Blocks\WriteOnceBlock.cs (1)
25
public sealed class WriteOnceBlock<T> : IPropagatorBlock<T, T>,
IReceivableSourceBlock
<T>, IDebuggerDisplay
16 references to IReceivableSourceBlock
System.Threading.Tasks.Dataflow (16)
Base\DataflowBlock.cs (11)
790
public static bool TryReceive<TOutput>(this
IReceivableSourceBlock
<TOutput> source, [MaybeNullWhen(false)] out TOutput item)
968
var
receivableSource = source as
IReceivableSourceBlock
<TOutput>;
1018
var
receivableSource = source as
IReceivableSourceBlock
<TOutput>;
1609
var
receivableSource = _source as
IReceivableSourceBlock
<TOutput>;
1619
var
receivableSource = _source as
IReceivableSourceBlock
<TOutput>;
1960
var
receivableSource = source as
IReceivableSourceBlock
<T>;
Base\DataflowBlock.IAsyncEnumerable.cs (2)
17
public static IAsyncEnumerable<TOutput> ReceiveAllAsync<TOutput>(this
IReceivableSourceBlock
<TOutput> source, CancellationToken cancellationToken = default)
26
static async IAsyncEnumerable<TOutput> Core(
IReceivableSourceBlock
<TOutput> source, [EnumeratorCancellation] CancellationToken cancellationToken)
Base\IReceivableSourceBlock.cs (1)
19
/// <typeparam name="TOutput">Specifies the type of data supplied by the <see cref="
IReceivableSourceBlock
{TOutput}"/>.</typeparam>
Blocks\BroadcastBlock.cs (1)
160
bool
IReceivableSourceBlock
<T>.TryReceiveAll([NotNullWhen(true)] out IList<T>? items) { return _source.TryReceiveAll(out items); }
Blocks\WriteOnceBlock.cs (1)
284
bool
IReceivableSourceBlock
<T>.TryReceiveAll([NotNullWhen(true)] out IList<T>? items)