Export (0) Print
Expand All

DataflowBlock Methods

.NET Framework 4.5

The DataflowBlock type exposes the following members.

  Name Description
Public method Static member AsObservable<TOutput> Creates a new IObservable<T> abstraction over the ISourceBlock<TOutput>.
Public method Static member AsObserver<TInput> Creates a new IObserver<T> abstraction over the ITargetBlock<TInput>.
Public method Static member Choose<T1, T2>(ISourceBlock<T1>, Action<T1>, ISourceBlock<T2>, Action<T2>) Monitors two dataflow sources, invoking the provided handler for whichever source makes data available first.
Public method Static member Choose<T1, T2>(ISourceBlock<T1>, Action<T1>, ISourceBlock<T2>, Action<T2>, DataflowBlockOptions) Monitors two dataflow sources, invoking the provided handler for whichever source makes data available first.
Public method Static member Choose<T1, T2, T3>(ISourceBlock<T1>, Action<T1>, ISourceBlock<T2>, Action<T2>, ISourceBlock<T3>, Action<T3>) Monitors three dataflow sources, invoking the provided handler for whichever source makes data available first.
Public method Static member Choose<T1, T2, T3>(ISourceBlock<T1>, Action<T1>, ISourceBlock<T2>, Action<T2>, ISourceBlock<T3>, Action<T3>, DataflowBlockOptions) Monitors three dataflow sources, invoking the provided handler for whichever source makes data available first.
Public method Static member Encapsulate<TInput, TOutput> Encapsulates a target and a source into a single propagator.
Public method Static member LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>) Links the ISourceBlock<TOutput> to the specified ITargetBlock<TInput>.
Public method Static member LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>, Predicate<TOutput>) Links the ISourceBlock<TOutput> to the specified ITargetBlock<TInput> using the specified filter.
Public method Static member LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>, DataflowLinkOptions, Predicate<TOutput>) Links the ISourceBlock<TOutput> to the specified ITargetBlock<TInput> using the specified filter.
Public method Static member NullTarget<TInput> Gets a target block that synchronously accepts all messages offered to it and drops them.
Public method Static member OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>) Provides a Task<TResult> that asynchronously monitors the source for available output.
Public method Static member OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>, CancellationToken) Provides a Task<TResult> that asynchronously monitors the source for available output.
Public method Static member Post<TInput> Posts an item to the ITargetBlock<TInput>.
Public method Static member Receive<TOutput>(ISourceBlock<TOutput>) Synchronously receives a value from a specified source.
Public method Static member Receive<TOutput>(ISourceBlock<TOutput>, CancellationToken) Synchronously receives a value from a specified source and provides a token to cancel the operation.
Public method Static member Receive<TOutput>(ISourceBlock<TOutput>, TimeSpan) Synchronously receives a value from a specified source, observing an optional time-out period.
Public method Static member Receive<TOutput>(ISourceBlock<TOutput>, TimeSpan, CancellationToken) Synchronously receives a value from a specified source, providing a token to cancel the operation and observing an optional time-out interval.
Public method Static member ReceiveAsync<TOutput>(ISourceBlock<TOutput>) Asynchronously receives a value from a specified source.
Public method Static member ReceiveAsync<TOutput>(ISourceBlock<TOutput>, CancellationToken) Asynchronously receives a value from a specified source and provides a token to cancel the operation.
Public method Static member ReceiveAsync<TOutput>(ISourceBlock<TOutput>, TimeSpan) Asynchronously receives a value from a specified source, observing an optional time-out period.
Public method Static member ReceiveAsync<TOutput>(ISourceBlock<TOutput>, TimeSpan, CancellationToken) Asynchronously receives a value from a specified source, providing a token to cancel the operation and observing an optional time-out interval.
Public method Static member SendAsync<TInput>(ITargetBlock<TInput>, TInput) Asynchronously offers a message to the target message block, allowing for postponement.
Public method Static member SendAsync<TInput>(ITargetBlock<TInput>, TInput, CancellationToken) Asynchronously offers a message to the target message block, allowing for postponement.
Public method Static member TryReceive<TOutput> Attempts to synchronously receive an item from the ISourceBlock<TOutput>.
Top
Show:
© 2014 Microsoft