ISourceBlock<TOutput> Interface

Definition

Represents a dataflow block that is a source of data.

public interface ISourceBlock<out TOutput> : System.Threading.Tasks.Dataflow.IDataflowBlock
Type Parameters
TOutput

Specifies the type of data supplied by the ISourceBlock<TOutput>.

Derived
Implements

Remarks

Note

The TPL Dataflow Library (System.Threading.Tasks.Dataflow namespace) is not distributed with the net_v45. To install the System.Threading.Tasks.Dataflow namespace, open your project in vs_dev11_long, choose Manage NuGet Packages from the Project menu, and search online for the Microsoft.Tpl.Dataflow package.

Methods

ConsumeMessage(DataflowMessageHeader, ITargetBlock<TOutput>, Boolean)

Called by a linked ITargetBlock<TInput> to accept and consume a T:System.Threading.Tasks.Dataflow.DataflowMessageHeader previously offered by this ISourceBlock<TOutput>.

LinkTo(ITargetBlock<TOutput>, DataflowLinkOptions)

Links the ISourceBlock<TOutput> to the specified ITargetBlock<TInput>.

ReleaseReservation(DataflowMessageHeader, ITargetBlock<TOutput>)

Called by a linked ITargetBlock<TInput> to release a previously reserved DataflowMessageHeader by this ISourceBlock<TOutput>.

ReserveMessage(DataflowMessageHeader, ITargetBlock<TOutput>)

Called by a linked ITargetBlock<TInput> to reserve a previously offered DataflowMessageHeader by this ISourceBlock<TOutput>.

Extension Methods

AsObservable<TOutput>(ISourceBlock<TOutput>)
LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>)
LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>, Predicate<TOutput>)
LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>, DataflowLinkOptions, Predicate<TOutput>)
OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>)
OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>, CancellationToken)
Receive<TOutput>(ISourceBlock<TOutput>)
Receive<TOutput>(ISourceBlock<TOutput>, CancellationToken)
Receive<TOutput>(ISourceBlock<TOutput>, TimeSpan)
Receive<TOutput>(ISourceBlock<TOutput>, TimeSpan, CancellationToken)
ReceiveAsync<TOutput>(ISourceBlock<TOutput>)
ReceiveAsync<TOutput>(ISourceBlock<TOutput>, CancellationToken)
ReceiveAsync<TOutput>(ISourceBlock<TOutput>, TimeSpan)
ReceiveAsync<TOutput>(ISourceBlock<TOutput>, TimeSpan, CancellationToken)