ISourceBlock<TOutput> Interfejs

Definicja

Przestrzeń nazw:

System.Threading.Tasks.Dataflow

Zestaw:

System.Threading.Tasks.Dataflow.dll

Pakiet:

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

Reprezentuje blok przepływu danych, który jest źródłem danych.

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

Parametry typu

TOutput

Określa typ danych dostarczonych przez ISourceBlock<TOutput>obiekt .

Ten parametr typu jest kowariantny. Oznacza to, że możesz użyć typu, który został przez Ciebie określony, lub dowolnego typu, który jest bardziej pochodny. Aby uzyskać więcej informacji o kowariancji i kontrawariancji, zobacz Kowariancja i kontrawariancja w typach ogólnych.

Pochodne

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>

Implementuje

IDataflowBlock

Uwagi

Uwaga

Biblioteka przepływu danych TPL ( System.Threading.Tasks.Dataflow przestrzeń nazw) nie jest dystrybuowana za pomocą platformy .NET. Aby zainstalować System.Threading.Tasks.Dataflow przestrzeń nazw w programie Visual Studio, otwórz projekt, wybierz pozycję Zarządzaj pakietami NuGet z menu Project i wyszukaj pakiet w trybie online System.Threading.Tasks.Dataflow . Alternatywnie, aby zainstalować go przy użyciu interfejsu wiersza polecenia platformy .NET Core, uruchom polecenie dotnet add package System.Threading.Tasks.Dataflow.

Właściwości

Completion

Pobiera element reprezentujący operację Task asynchroniczną i ukończenie bloku przepływu danych. (Odziedziczone po IDataflowBlock)

Metody

Complete()	Sygnały do IDataflowBlock tego, że nie powinny akceptować ani tworzyć więcej komunikatów, ani nie zużywać żadnych bardziej odroczonych komunikatów. (Odziedziczone po IDataflowBlock)
ConsumeMessage(DataflowMessageHeader, ITargetBlock<TOutput>, Boolean)	Wywołana przez link ITargetBlock<TInput> do akceptowania i korzystania z wcześniej oferowanej przez tę ISourceBlock<TOutput>usługę DataflowMessageHeader .
Fault(Exception)	IDataflowBlock Powoduje ukończenie Faulted operacji w stanie. (Odziedziczone po IDataflowBlock)
LinkTo(ITargetBlock<TOutput>, DataflowLinkOptions)	Łączy element ISourceBlock<TOutput> z określonym ITargetBlock<TInput>elementem .
ReleaseReservation(DataflowMessageHeader, ITargetBlock<TOutput>)	Wywoływana przez połączony ITargetBlock<TInput> element z wydaniem wcześniej zastrzeżonym DataflowMessageHeader przez ten ISourceBlock<TOutput>element .
ReserveMessage(DataflowMessageHeader, ITargetBlock<TOutput>)	Wywoływana przez połączonego ITargetBlock<TInput> z rezerwą wcześniej oferowaną DataflowMessageHeader przez tę ISourceBlock<TOutput>usługę .

Metody rozszerzania

AsObservable<TOutput>(ISourceBlock<TOutput>)	Tworzy nową IObservable<T> abstrakcję nad elementem ISourceBlock<TOutput>.
LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>)	Łączy element ISourceBlock<TOutput> z określonym ITargetBlock<TInput>elementem .
LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>, Predicate<TOutput>)	Łączy element ISourceBlock<TOutput> z określonym ITargetBlock<TInput> filtrem przy użyciu określonego filtru.
LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>, DataflowLinkOptions, Predicate<TOutput>)	Łączy element ISourceBlock<TOutput> z określonym ITargetBlock<TInput> filtrem przy użyciu określonego filtru.
OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>)	Task<TResult> Zapewnia, że asynchronicznie monitoruje źródło dostępnych danych wyjściowych.
OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>, CancellationToken)	Task<TResult> Zapewnia, że asynchronicznie monitoruje źródło dostępnych danych wyjściowych.
Receive<TOutput>(ISourceBlock<TOutput>)	Synchronicznie odbiera wartość z określonego źródła.
Receive<TOutput>(ISourceBlock<TOutput>, CancellationToken)	Synchronicznie odbiera wartość z określonego źródła i udostępnia token do anulowania operacji.
Receive<TOutput>(ISourceBlock<TOutput>, TimeSpan)	Synchronicznie odbiera wartość z określonego źródła, obserwując opcjonalny okres przekroczenia limitu czasu.
Receive<TOutput>(ISourceBlock<TOutput>, TimeSpan, CancellationToken)	Synchronicznie odbiera wartość z określonego źródła, zapewniając token umożliwiający anulowanie operacji i obserwowanie opcjonalnego interwału przekroczenia limitu czasu.
ReceiveAsync<TOutput>(ISourceBlock<TOutput>)	Asynchronicznie odbiera wartość z określonego źródła.
ReceiveAsync<TOutput>(ISourceBlock<TOutput>, CancellationToken)	Asynchronicznie odbiera wartość z określonego źródła i udostępnia token do anulowania operacji.
ReceiveAsync<TOutput>(ISourceBlock<TOutput>, TimeSpan)	Asynchronicznie odbiera wartość z określonego źródła, obserwując opcjonalny okres przekroczenia limitu czasu.
ReceiveAsync<TOutput>(ISourceBlock<TOutput>, TimeSpan, CancellationToken)	Asynchronicznie odbiera wartość z określonego źródła, zapewniając token umożliwiający anulowanie operacji i obserwowanie opcjonalnego interwału przekroczenia limitu czasu.