IReceivableSourceBlock<TOutput> Schnittstelle

Definition

Namespace:
System.Threading.Tasks.Dataflow
Assembly:
System.Threading.Tasks.Dataflow.dll
Paket:
System.Threading.Tasks.Dataflow v11.0.0-preview.4.26230.115
Quelle:
IReceivableSourceBlock.cs
Quelle:
IReceivableSourceBlock.cs
Quelle:
IReceivableSourceBlock.cs
Quelle:
DataflowMessageHeader.cs

Stellt einen Datenflussblock dar, der das Empfangen von Nachrichten ohne Verknüpfung unterstützt.

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)

Typparameter

TOutput

Gibt den Typ der daten an, die von der .IReceivableSourceBlock<TOutput>

Abgeleitet
Implementiert
IDataflowBlock ISourceBlock<TOutput>

Hinweise

Note

Die TPL Dataflow Library (der System.Threading.Tasks.Dataflow Namespace) wird nicht mit .NET verteilt. Um den System.Threading.Tasks.Dataflow Namespace in Visual Studio zu installieren, öffnen Sie Ihr Projekt, wählen Sie "NuGet-Pakete verwalten " im Menü "Projekt " aus, und suchen Sie online nach dem System.Threading.Tasks.Dataflow Paket. Führen Sie alternativ das .NET Core CLI aus, um es zu installieren, indem Sie dotnet add package System.Threading.Tasks.Dataflow ausführen.

Eigenschaften

Name Beschreibung
Completion

Ruft einen Task , der den asynchronen Vorgang und den Abschluss des Datenflussblocks darstellt.

(Geerbt von IDataflowBlock)

Methoden

Name Beschreibung
Complete()

Signalisiert, IDataflowBlock dass sie weder mehr Nachrichten akzeptieren noch mehr nachrichten produzieren sollte, noch mehr verschobene Nachrichten verbrauchen.

(Geerbt von IDataflowBlock)
ConsumeMessage(DataflowMessageHeader, ITargetBlock<TOutput>, Boolean)

Wird von einer verknüpften aufgerufen ITargetBlock<TInput> , um eine DataflowMessageHeader zuvor angebotene ISourceBlock<TOutput>Nutzung zu akzeptieren und zu nutzen.

(Geerbt von ISourceBlock<TOutput>)
Fault(Exception)

Bewirkt, dass der IDataflowBlock Vorgang in einem Faulted Zustand abgeschlossen ist.

(Geerbt von IDataflowBlock)
LinkTo(ITargetBlock<TOutput>, DataflowLinkOptions)

Verknüpft den ISourceBlock<TOutput> angegebenen ITargetBlock<TInput>Wert.

(Geerbt von ISourceBlock<TOutput>)
ReleaseReservation(DataflowMessageHeader, ITargetBlock<TOutput>)

Wird von einem Verknüpften ITargetBlock<TInput> aufgerufen, um eine zuvor reservierte DataflowMessageHeader Version dieses ISourceBlock<TOutput>Vorgangs freizugeben.

(Geerbt von ISourceBlock<TOutput>)
ReserveMessage(DataflowMessageHeader, ITargetBlock<TOutput>)

Aufgerufen von einem verknüpften ITargetBlock<TInput> , um ein zuvor angebotenes DataflowMessageHeader Angebot zu ISourceBlock<TOutput>reservieren.

(Geerbt von ISourceBlock<TOutput>)
TryReceive(Predicate<TOutput>, TOutput)

Versucht, synchron ein verfügbares Ausgabeelement von der IReceivableSourceBlock<TOutput>.
TryReceiveAll(IList<TOutput>)

Versucht, alle verfügbaren Elemente synchron von der IReceivableSourceBlock<TOutput>.

Erweiterungsmethoden

Name Beschreibung
AsObservable<TOutput>(ISourceBlock<TOutput>)

Erstellt eine neue IObservable<T> Abstraktion über dem ISourceBlock<TOutput>.
LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>, DataflowLinkOptions, Predicate<TOutput>)

Verknüpft den ISourceBlock<TOutput> angegebenen Filter mit dem angegebenen ITargetBlock<TInput> Filter.
LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>, Predicate<TOutput>)

Verknüpft den ISourceBlock<TOutput> angegebenen Filter mit dem angegebenen ITargetBlock<TInput> Filter.
LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>)

Verknüpft den ISourceBlock<TOutput> angegebenen ITargetBlock<TInput>Wert.
OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>, CancellationToken)

Stellt eine Bereit Task<TResult> , die die Quelle asynchron auf die verfügbare Ausgabe überwacht.
OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>)

Stellt eine Bereit Task<TResult> , die die Quelle asynchron auf die verfügbare Ausgabe überwacht.
Receive<TOutput>(ISourceBlock<TOutput>, CancellationToken)

Empfängt synchron einen Wert aus einer angegebenen Quelle und stellt ein Token zum Abbrechen des Vorgangs bereit.
Receive<TOutput>(ISourceBlock<TOutput>, TimeSpan, CancellationToken)

Empfängt synchron einen Wert aus einer angegebenen Quelle und stellt ein Token bereit, um den Vorgang abzubrechen und ein optionales Timeoutintervall zu beobachten.
Receive<TOutput>(ISourceBlock<TOutput>, TimeSpan)

Empfängt synchron einen Wert aus einer angegebenen Quelle, wobei ein optionaler Timeoutzeitraum beobachtet wird.
Receive<TOutput>(ISourceBlock<TOutput>)

Empfängt synchron einen Wert aus einer angegebenen Quelle.
ReceiveAllAsync<TOutput>(IReceivableSourceBlock<TOutput>, CancellationToken)

Erstellt eine IAsyncEnumerable<T> , die das Empfangen aller Daten aus der Quelle ermöglicht.
ReceiveAsync<TOutput>(ISourceBlock<TOutput>, CancellationToken)

Empfängt asynchron einen Wert aus einer angegebenen Quelle und stellt ein Token zum Abbrechen des Vorgangs bereit.
ReceiveAsync<TOutput>(ISourceBlock<TOutput>, TimeSpan, CancellationToken)

Empfängt asynchron einen Wert aus einer angegebenen Quelle und stellt ein Token bereit, um den Vorgang abzubrechen und ein optionales Timeoutintervall zu beobachten.
ReceiveAsync<TOutput>(ISourceBlock<TOutput>, TimeSpan)

Empfängt asynchron einen Wert aus einer angegebenen Quelle, wobei ein optionaler Timeoutzeitraum beobachtet wird.
ReceiveAsync<TOutput>(ISourceBlock<TOutput>)

Empfängt asynchron einen Wert aus einer angegebenen Quelle.
TryReceive<TOutput>(IReceivableSourceBlock<TOutput>, TOutput)

Versucht, ein Element synchron von der ISourceBlock<TOutput>.

Gilt für: