ISourceBlock<TOutput> Interface
Represents a dataflow block that is a source of data.
Assembly: System.Threading.Tasks.Dataflow (in System.Threading.Tasks.Dataflow.dll)
| Name | Description | |
|---|---|---|
![]() | Completion | Gets a Task that represents the asynchronous operation and completion of the dataflow block.(Inherited from IDataflowBlock.) |
| Name | Description | |
|---|---|---|
![]() | Complete() | Signals to the IDataflowBlock that it should not accept nor produce any more messages nor consume any more postponed messages.(Inherited from IDataflowBlock.) |
![]() | 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>. |
![]() | Fault(Exception^) | Causes the IDataflowBlock to complete in a Faulted state.(Inherited from IDataflowBlock.) |
![]() | 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>. |
| Name | Description | |
|---|---|---|
![]() | AsObservable<TOutput>() | Creates a new IObservable<T> abstraction over the ISourceBlock<TOutput>.(Defined by DataflowBlock.) |
![]() | LinkTo<TOutput>(ITargetBlock<TOutput>^) | Overloaded. Links the ISourceBlock<TOutput> to the specified ITargetBlock<TInput>. (Defined by DataflowBlock.) |
![]() | LinkTo<TOutput>(ITargetBlock<TOutput>^, DataflowLinkOptions^, Predicate<TOutput>^) | Overloaded. Links the ISourceBlock<TOutput> to the specified ITargetBlock<TInput> using the specified filter. (Defined by DataflowBlock.) |
![]() | LinkTo<TOutput>(ITargetBlock<TOutput>^, Predicate<TOutput>^) | Overloaded. Links the ISourceBlock<TOutput> to the specified ITargetBlock<TInput> using the specified filter. (Defined by DataflowBlock.) |
![]() | OutputAvailableAsync<TOutput>() | Overloaded. Provides a Task<TResult> that asynchronously monitors the source for available output.(Defined by DataflowBlock.) |
![]() | OutputAvailableAsync<TOutput>(CancellationToken) | Overloaded. Provides a Task<TResult> that asynchronously monitors the source for available output. (Defined by DataflowBlock.) |
![]() | Receive<TOutput>() | Overloaded. Synchronously receives a value from a specified source.(Defined by DataflowBlock.) |
![]() | Receive<TOutput>(CancellationToken) | Overloaded. Synchronously receives a value from a specified source and provides a token to cancel the operation. (Defined by DataflowBlock.) |
![]() | Receive<TOutput>(TimeSpan) | Overloaded. Synchronously receives a value from a specified source, observing an optional time-out period.(Defined by DataflowBlock.) |
![]() | Receive<TOutput>(TimeSpan, CancellationToken) | Overloaded. Synchronously receives a value from a specified source, providing a token to cancel the operation and observing an optional time-out interval. (Defined by DataflowBlock.) |
![]() | ReceiveAsync<TOutput>() | Overloaded. Asynchronously receives a value from a specified source.(Defined by DataflowBlock.) |
![]() | ReceiveAsync<TOutput>(CancellationToken) | Overloaded. Asynchronously receives a value from a specified source and provides a token to cancel the operation. (Defined by DataflowBlock.) |
![]() | ReceiveAsync<TOutput>(TimeSpan) | Overloaded. Asynchronously receives a value from a specified source, observing an optional time-out period.(Defined by DataflowBlock.) |
![]() | ReceiveAsync<TOutput>(TimeSpan, CancellationToken) | Overloaded. Asynchronously receives a value from a specified source, providing a token to cancel the operation and observing an optional time-out interval. (Defined by DataflowBlock.) |
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. |


