Lenguaje

ISourceBlock<TOutput> Interfaz

Definición

Representa un bloque de flujo de datos que es un origen de datos.

generic <typename TOutput>
public interface class ISourceBlock : System::Threading::Tasks::Dataflow::IDataflowBlock
public interface ISourceBlock<out TOutput> : System.Threading.Tasks.Dataflow.IDataflowBlock
type ISourceBlock<'Output> = interface
    interface IDataflowBlock
Public Interface ISourceBlock(Of Out TOutput)
Implements IDataflowBlock

Parámetros de tipo

TOutput

Especifica el tipo de datos proporcionados por .ISourceBlock<TOutput>

Este parámetro de tipo es covariante, es decir, puede usar el tipo que haya especificado o cualquier tipo más derivado. Si desea obtener más información sobre la covarianza y la contravarianza, consulte Covarianza y contravarianza en genéricos.
Derivado
Implementaciones

Propiedades

Nombre Description
Completion

Obtiene un Task objeto que representa la operación asincrónica y la finalización del bloque de flujo de datos.

(Heredado de IDataflowBlock)

Métodos

Nombre Description
Complete()

Señala a que IDataflowBlock no debe aceptar ni producir más mensajes ni consumir más mensajes pospuestos.

(Heredado de IDataflowBlock)
ConsumeMessage(DataflowMessageHeader, ITargetBlock<TOutput>, Boolean)

Llamado por un vinculado ITargetBlock<TInput> para aceptar y consumir un DataflowMessageHeader objeto previamente ofrecido por este ISourceBlock<TOutput>.

Fault(Exception)

Hace que se IDataflowBlock complete en un Faulted estado .

(Heredado de IDataflowBlock)
LinkTo(ITargetBlock<TOutput>, DataflowLinkOptions)

Vincula al ISourceBlock<TOutput> objeto especificado ITargetBlock<TInput>.

ReleaseReservation(DataflowMessageHeader, ITargetBlock<TOutput>)

Llamado por un vinculado ITargetBlock<TInput> para liberar un objeto reservado DataflowMessageHeader previamente por este ISourceBlock<TOutput>.

ReserveMessage(DataflowMessageHeader, ITargetBlock<TOutput>)

Llamado por un vinculado ITargetBlock<TInput> para reservar un objeto ofrecido DataflowMessageHeader anteriormente por este ISourceBlock<TOutput>.

Métodos de extensión

Nombre Description
AsObservable<TOutput>(ISourceBlock<TOutput>)

Crea una nueva IObservable<T> abstracción sobre .ISourceBlock<TOutput>

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>.

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.

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.

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.

Se aplica a