IReceivableSourceBlock<TOutput> Interfaccia

  • Riferimento

Definizione

Spazio dei nomi:
System.Threading.Tasks.Dataflow
Assembly:
System.Threading.Tasks.Dataflow.dll
Pacchetto:
System.Threading.Tasks.Dataflow v8.0.0
Pacchetto:
System.Threading.Tasks.Dataflow v9.0.0-preview.3.24172.9

Rappresenta un blocco del flusso di dati che supporta la ricezione di messaggi senza collegamento.

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)

Parametri di tipo

TOutput

Specifica il tipo di dati forniti da IReceivableSourceBlock<TOutput>.

Derivato
Implementazioni
IDataflowBlock ISourceBlock<TOutput>

Commenti

Nota

La libreria del flusso di dati TPL (spazio dei nomi System.Threading.Tasks.Dataflow) non viene distribuita con .NET. Per installare lo spazio dei nomi System.Threading.Tasks.Dataflow in Visual Studio, aprire il progetto in Visual Studio, scegliere Gestisci pacchetti NuGet dal menu Progetto ed eseguire una ricerca online del pacchetto System.Threading.Tasks.Dataflow. In alternativa, per installarlo usando l'interfaccia della riga di comando di .NET Core, eseguire dotnet add package System.Threading.Tasks.Dataflow.

Proprietà

Completion

Ottiene un Task che rappresenta l'operazione asincrona e il completamento del blocco di flussi di dati.

(Ereditato da IDataflowBlock)

Metodi

Complete()

Segnala al IDataflowBlock che non deve accettare o produrre altri messaggi e non deve utilizzare altri messaggi posticipati.

(Ereditato da IDataflowBlock)
ConsumeMessage(DataflowMessageHeader, ITargetBlock<TOutput>, Boolean)

Chiamato da un ITargetBlock<TInput> collegato per accettare e utilizzare DataflowMessageHeader precedentemente offerto da questo ISourceBlock<TOutput>.

(Ereditato da ISourceBlock<TOutput>)
Fault(Exception)

Determina il completamento di IDataflowBlock in uno stato di Faulted .

(Ereditato da IDataflowBlock)
LinkTo(ITargetBlock<TOutput>, DataflowLinkOptions)

Collega l'oggetto ISourceBlock<TOutput> all'oggetto specificato ITargetBlock<TInput>.

(Ereditato da ISourceBlock<TOutput>)
ReleaseReservation(DataflowMessageHeader, ITargetBlock<TOutput>)

Chiamato da un ITargetBlock<TInput> collegato per rilasciare un DataflowMessageHeader precedentemente riservato da questo ISourceBlock<TOutput>.

(Ereditato da ISourceBlock<TOutput>)
ReserveMessage(DataflowMessageHeader, ITargetBlock<TOutput>)

Chiamato da un ITargetBlock<TInput> collegato per conservare un DataflowMessageHeader precedentemente offerto da questo ISourceBlock<TOutput>.

(Ereditato da ISourceBlock<TOutput>)
TryReceive(Predicate<TOutput>, TOutput)

Tenta di ricevere in modo sincrono un elemento di output disponibile da IReceivableSourceBlock<TOutput>.
TryReceiveAll(IList<TOutput>)

Tenta di ricevere in modo sincrono tutti gli elementi disponibili dal IReceivableSourceBlock<TOutput>.

Metodi di estensione

AsObservable<TOutput>(ISourceBlock<TOutput>)

Crea una nuova astrazione IObservable<T> rispetto a ISourceBlock<TOutput>.
LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>)

Collega l'oggetto ISourceBlock<TOutput> all'oggetto specificato ITargetBlock<TInput>.
LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>, Predicate<TOutput>)

Collega l'oggetto ISourceBlock<TOutput> all'oggetto specificato ITargetBlock<TInput> utilizzando il filtro specificato.
LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>, DataflowLinkOptions, Predicate<TOutput>)

Collega l'oggetto ISourceBlock<TOutput> all'oggetto specificato ITargetBlock<TInput> utilizzando il filtro specificato.
OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>)

Fornisce un oggetto Task<TResult> che monitora in modo asincrono l'origine per l'output disponibile.
OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>, CancellationToken)

Fornisce un oggetto Task<TResult> che monitora in modo asincrono l'origine per l'output disponibile.
Receive<TOutput>(ISourceBlock<TOutput>)

Riceve un valore in modo sincrono da un'origine specificata.
Receive<TOutput>(ISourceBlock<TOutput>, CancellationToken)

Riceve in modo sincrono un valore da un'origine specificata e fornisce un token per annullare l'operazione.
Receive<TOutput>(ISourceBlock<TOutput>, TimeSpan)

Riceve in modo sincrono un valore da un'origine specificata, osservando un periodo di timeout facoltativo.
Receive<TOutput>(ISourceBlock<TOutput>, TimeSpan, CancellationToken)

Riceve in modo sincrono un valore da un'origine specificata, fornendo un token per annullare l'operazione e osservando un intervallo di timeout facoltativo.
ReceiveAllAsync<TOutput>(IReceivableSourceBlock<TOutput>, CancellationToken)

Crea un oggetto IAsyncEnumerable<T> che consente la ricezione di tutti i dati dall'origine.
ReceiveAsync<TOutput>(ISourceBlock<TOutput>)

Riceve un valore in modo asincrono da un'origine specificata.
ReceiveAsync<TOutput>(ISourceBlock<TOutput>, CancellationToken)

Riceve in modo asincrono un valore da un'origine specificata e fornisce un token per annullare l'operazione.
ReceiveAsync<TOutput>(ISourceBlock<TOutput>, TimeSpan)

Riceve in modo asincrono un valore da un'origine specificata, osservando un periodo di timeout facoltativo.
ReceiveAsync<TOutput>(ISourceBlock<TOutput>, TimeSpan, CancellationToken)

Riceve in modo asincrono un valore da un'origine specificata, fornendo un token per annullare l'operazione e osservando un intervallo di timeout facoltativo.
TryReceive<TOutput>(IReceivableSourceBlock<TOutput>, TOutput)

Tenta di ricevere in modo sincrono un elemento da ISourceBlock<TOutput>.

Si applica a