ISourceBlock<TOutput> Interfaccia

Definizione

Spazio dei nomi:

System.Threading.Tasks.Dataflow

Assembly:

System.Threading.Tasks.Dataflow.dll

Pacchetto:

System.Threading.Tasks.Dataflow v9.0.0-rc.1.24431.7

Rappresenta un blocco del flusso di dati che è un'origine dati.

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

Parametri di tipo

TOutput

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

Questo parametro di tipo è covariante, ovvero puoi usare il tipo specificato o qualsiasi tipo più derivato. Per altre informazioni sulla covarianza e la controvarianza, vedi Covarianza e controvarianza nei generics.

Derivato

System.Threading.Tasks.Dataflow.BatchBlock<T>

System.Threading.Tasks.Dataflow.BatchedJoinBlock<T1,T2>

System.Threading.Tasks.Dataflow.BatchedJoinBlock<T1,T2,T3>

System.Threading.Tasks.Dataflow.BroadcastBlock<T>

System.Threading.Tasks.Dataflow.BufferBlock<T>

System.Threading.Tasks.Dataflow.IPropagatorBlock<TInput,TOutput>

System.Threading.Tasks.Dataflow.IReceivableSourceBlock<TOutput>

System.Threading.Tasks.Dataflow.JoinBlock<T1,T2>

System.Threading.Tasks.Dataflow.JoinBlock<T1,T2,T3>

System.Threading.Tasks.Dataflow.TransformBlock<TInput,TOutput>

System.Threading.Tasks.Dataflow.TransformManyBlock<TInput,TOutput>

System.Threading.Tasks.Dataflow.WriteOnceBlock<T>

Implementazioni

IDataflowBlock

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>.
Fault(Exception)	Determina il completamento di IDataflowBlock in uno stato di Faulted . (Ereditato da IDataflowBlock)
LinkTo(ITargetBlock<TOutput>, DataflowLinkOptions)	Collega l'oggetto all'oggetto ISourceBlock<TOutput> specificato ITargetBlock<TInput>.
ReleaseReservation(DataflowMessageHeader, ITargetBlock<TOutput>)	Chiamato da un ITargetBlock<TInput> collegato per rilasciare un DataflowMessageHeader precedentemente riservato da questo ISourceBlock<TOutput>.
ReserveMessage(DataflowMessageHeader, ITargetBlock<TOutput>)	Chiamato da un ITargetBlock<TInput> collegato per conservare un DataflowMessageHeader precedentemente offerto da questo ISourceBlock<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 all'oggetto ISourceBlock<TOutput> specificato ITargetBlock<TInput>.
LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>, Predicate<TOutput>)	Collega l'oggetto ISourceBlock<TOutput> all'oggetto specificato usando il filtro specificato ITargetBlock<TInput> .
LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>, DataflowLinkOptions, Predicate<TOutput>)	Collega l'oggetto ISourceBlock<TOutput> all'oggetto specificato usando il filtro specificato ITargetBlock<TInput> .
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.
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.