Lenguaje

IReceivableSourceBlock<TOutput> Interfaz

Definición

Espacio de nombres:
System.Threading.Tasks.Dataflow
Ensamblado:
System.Threading.Tasks.Dataflow.dll
Paquete:
System.Threading.Tasks.Dataflow v11.0.0-rc.1.26425.128
Source:
IReceivableSourceBlock.cs
Source:
IReceivableSourceBlock.cs
Source:
IReceivableSourceBlock.cs
Source:
IReceivableSourceBlock.cs
Source:
DataflowMessageHeader.cs

Representa un bloque de flujo de datos que admite la recepción de mensajes sin vincular.

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

Parámetros de tipo

TOutput

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

Derivado
Implementaciones
IDataflowBlock ISourceBlock<TOutput>

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

(Heredado de 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>.

(Heredado de ISourceBlock<TOutput>)
ReleaseReservation(DataflowMessageHeader, ITargetBlock<TOutput>)

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

(Heredado de ISourceBlock<TOutput>)
ReserveMessage(DataflowMessageHeader, ITargetBlock<TOutput>)

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

(Heredado de ISourceBlock<TOutput>)
TryReceive(Predicate<TOutput>, TOutput)

Intenta recibir de forma sincrónica un elemento de salida disponible de .IReceivableSourceBlock<TOutput>
TryReceiveAll(IList<TOutput>)

Intenta recibir de forma sincrónica todos los elementos disponibles de IReceivableSourceBlock<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.
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.
TryReceive<TOutput>(IReceivableSourceBlock<TOutput>, TOutput)

Intenta recibir de forma sincrónica un elemento de .ISourceBlock<TOutput>

Se aplica a