DataflowBlock Clase
Definición
Importante
Parte de la información hace referencia a la versión preliminar del producto, que puede haberse modificado sustancialmente antes de lanzar la versión definitiva. Microsoft no otorga ninguna garantía, explícita o implícita, con respecto a la información proporcionada aquí.
Proporciona un conjunto de métodos estáticos (compartidos en Visual Basic) para trabajar con bloques de flujo de datos.
public ref class DataflowBlock abstract sealedpublic static class DataflowBlocktype DataflowBlock = classPublic Module DataflowBlock- Herencia
-
DataflowBlock
Comentarios
Note
La biblioteca TPL Dataflow (el espacio de nombres System.Threading.Tasks.Dataflow) no se distribuye con .NET. Para instalar el System.Threading.Tasks.Dataflow espacio de nombres en Visual Studio, abra su proyecto, elija Administrar paquetes NuGet en el menú Proyecto y busque en línea el paquete System.Threading.Tasks.Dataflow. Como otra opción, para instalarlo mediante la CLI de .NET Core, ejecute dotnet add package System.Threading.Tasks.Dataflow.
Métodos
| Nombre | Description |
|---|---|
| AsObservable<TOutput>(ISourceBlock<TOutput>) |
Crea una nueva IObservable<T> abstracción sobre .ISourceBlock<TOutput> |
| AsObserver<TInput>(ITargetBlock<TInput>) |
Crea una nueva IObserver<T> abstracción sobre .ITargetBlock<TInput> |
| Choose<T1,T2,T3>(ISourceBlock<T1>, Action<T1>, ISourceBlock<T2>, Action<T2>, ISourceBlock<T3>, Action<T3>, DataflowBlockOptions) |
Supervisa tres orígenes de flujo de datos, invocando el controlador proporcionado para cada origen que haga que los datos estén disponibles primero. |
| Choose<T1,T2,T3>(ISourceBlock<T1>, Action<T1>, ISourceBlock<T2>, Action<T2>, ISourceBlock<T3>, Action<T3>) |
Supervisa tres orígenes de flujo de datos, invocando el controlador proporcionado para cada origen que haga que los datos estén disponibles primero. |
| Choose<T1,T2>(ISourceBlock<T1>, Action<T1>, ISourceBlock<T2>, Action<T2>, DataflowBlockOptions) |
Supervisa dos orígenes de flujo de datos, invocando el controlador proporcionado para cada origen que haga que los datos estén disponibles primero. |
| Choose<T1,T2>(ISourceBlock<T1>, Action<T1>, ISourceBlock<T2>, Action<T2>) |
Supervisa dos orígenes de flujo de datos, invocando el controlador proporcionado para cada origen que haga que los datos estén disponibles primero. |
| Encapsulate<TInput,TOutput>(ITargetBlock<TInput>, ISourceBlock<TOutput>) |
Encapsula un destino y un origen en un único propagador. |
| LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>, DataflowLinkOptions, Predicate<TOutput>) |
ISourceBlock<TOutput> Vincula al especificado ITargetBlock<TInput> mediante el filtro especificado. |
| LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>, Predicate<TOutput>) |
ISourceBlock<TOutput> Vincula al especificado ITargetBlock<TInput> mediante el filtro especificado. |
| LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>) |
Vincula al ISourceBlock<TOutput> objeto especificado ITargetBlock<TInput>. |
| NullTarget<TInput>() |
Obtiene un bloque de destino que acepta de forma sincrónica todos los mensajes que se le ofrecen y los quita. |
| OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>, CancellationToken) |
Proporciona un objeto Task<TResult> que supervisa de forma asincrónica el origen de la salida disponible. |
| OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>) |
Proporciona un objeto Task<TResult> que supervisa de forma asincrónica el origen de la salida disponible. |
| Post<TInput>(ITargetBlock<TInput>, TInput) |
Publica un elemento en .ITargetBlock<TInput> |
| Receive<TOutput>(ISourceBlock<TOutput>, CancellationToken) |
Recibe sincrónicamente un valor de un origen especificado y proporciona un token para cancelar la operación. |
| Receive<TOutput>(ISourceBlock<TOutput>, TimeSpan, CancellationToken) |
Recibe sincrónicamente un valor de un origen especificado, proporcionando un token para cancelar la operación y observar un intervalo de tiempo de espera opcional. |
| Receive<TOutput>(ISourceBlock<TOutput>, TimeSpan) |
Recibe sincrónicamente un valor de un origen especificado, observando un período de tiempo de espera opcional. |
| Receive<TOutput>(ISourceBlock<TOutput>) |
Recibe sincrónicamente un valor de un origen especificado. |
| ReceiveAllAsync<TOutput>(IReceivableSourceBlock<TOutput>, CancellationToken) |
Crea un objeto IAsyncEnumerable<T> que permite recibir todos los datos del origen. |
| ReceiveAsync<TOutput>(ISourceBlock<TOutput>, CancellationToken) |
Recibe de forma asincrónica un valor de un origen especificado y proporciona un token para cancelar la operación. |
| ReceiveAsync<TOutput>(ISourceBlock<TOutput>, TimeSpan, CancellationToken) |
Recibe de forma asincrónica un valor de un origen especificado, lo que proporciona un token para cancelar la operación y observar un intervalo de tiempo de espera opcional. |
| ReceiveAsync<TOutput>(ISourceBlock<TOutput>, TimeSpan) |
Recibe de forma asincrónica un valor de un origen especificado, observando un período de tiempo de espera opcional. |
| ReceiveAsync<TOutput>(ISourceBlock<TOutput>) |
Recibe de forma asincrónica un valor de un origen especificado. |
| SendAsync<TInput>(ITargetBlock<TInput>, TInput, CancellationToken) |
Ofrece de forma asincrónica un mensaje al bloque de mensajes de destino, lo que permite posponer. |
| SendAsync<TInput>(ITargetBlock<TInput>, TInput) |
Ofrece de forma asincrónica un mensaje al bloque de mensajes de destino, lo que permite posponer. |
| TryReceive<TOutput>(IReceivableSourceBlock<TOutput>, TOutput) |
Intenta recibir de forma sincrónica un elemento de .ISourceBlock<TOutput> |
