IPropagatorBlock<TInput,TOutput> Interface

Definitie

Vertegenwoordigt een gegevensstroomblok dat zowel een doel is voor gegevens als een gegevensbron.

generic <typename TInput, typename TOutput>
public interface class IPropagatorBlock : System::Threading::Tasks::Dataflow::ISourceBlock<TOutput>, System::Threading::Tasks::Dataflow::ITargetBlock<TInput>
public interface IPropagatorBlock<in TInput,out TOutput> : System.Threading.Tasks.Dataflow.ISourceBlock<out TOutput>, System.Threading.Tasks.Dataflow.ITargetBlock<in TInput>
type IPropagatorBlock<'Input, 'Output> = interface
    interface ITargetBlock<'Input>
    interface IDataflowBlock
    interface ISourceBlock<'Output>
type IPropagatorBlock<'Input, 'Output> = interface
    interface IDataflowBlock
    interface ISourceBlock<'Output>
    interface ITargetBlock<'Input>
Public Interface IPropagatorBlock(Of In TInput, Out TOutput)
Implements ISourceBlock(Of Out TOutput), ITargetBlock(Of In TInput)

Type parameters

TInput

Hiermee geeft u het type gegevens dat wordt geaccepteerd door de IPropagatorBlock<TInput,TOutput>.

Dit type parameter is contravariant. U kunt het type dat u hebt opgegeven gebruiken of een type dat minder is afgeleid. Zie Covariantie en Contravariantie in Algemene typen voor meer informatie over covariantie en contravariantie.
TOutput

Hiermee geeft u het type gegevens op dat door de IPropagatorBlock<TInput,TOutput>.

Dit type parameter is covariant. U kunt het type dat u hebt opgegeven gebruiken of een type dat meer is afgeleid. Zie Covariantie en Contravariantie in Algemene typen voor meer informatie over covariantie en contravariantie.
Afgeleid
Implementeringen

Opmerkingen

Note

De TPL-gegevensstroombibliotheek (de System.Threading.Tasks.Dataflow naamruimte) wordt niet gedistribueerd met .NET. Als u de System.Threading.Tasks.Dataflow-naamruimte in Visual Studio wilt installeren, opent u uw project, kiest u NuGet-pakketten beheren in het menu Project en zoekt u online naar het System.Threading.Tasks.Dataflow-pakket. Om deze te installeren met behulp van de .NET Core CLI, voert u dotnet add package System.Threading.Tasks.Dataflowuit.

Eigenschappen

Name Description
Completion

Hiermee wordt een Task bestand opgehaald dat de asynchrone bewerking en voltooiing van het gegevensstroomblok vertegenwoordigt.

(Overgenomen van IDataflowBlock)

Methoden

Name Description
Complete()

Signalen voor het IDataflowBlock feit dat het niet meer berichten mag accepteren of produceren en geen uitgestelde berichten meer verbruiken.

(Overgenomen van IDataflowBlock)
ConsumeMessage(DataflowMessageHeader, ITargetBlock<TOutput>, Boolean)

Wordt aangeroepen door een gekoppeld om ITargetBlock<TInput> een DataflowMessageHeader eerder aangeboden door deze ISourceBlock<TOutput>te accepteren en te gebruiken.

(Overgenomen van ISourceBlock<TOutput>)
Fault(Exception)

Zorgt ervoor dat de IDataflowBlock status wordt voltooid Faulted .

(Overgenomen van IDataflowBlock)
LinkTo(ITargetBlock<TOutput>, DataflowLinkOptions)

Hiermee koppelt u de ISourceBlock<TOutput> opgegeven ITargetBlock<TInput>.

(Overgenomen van ISourceBlock<TOutput>)
OfferMessage(DataflowMessageHeader, TInput, ISourceBlock<TInput>, Boolean)

Biedt een bericht aan de ITargetBlock<TInput>, waardoor het doel de mogelijkheid heeft om het bericht te gebruiken of uit te stellen.

(Overgenomen van ITargetBlock<TInput>)
ReleaseReservation(DataflowMessageHeader, ITargetBlock<TOutput>)

Aangeroepen door een gekoppeld om ITargetBlock<TInput> een eerder gereserveerde DataflowMessageHeaderISourceBlock<TOutput>versie vrij te geven.

(Overgenomen van ISourceBlock<TOutput>)
ReserveMessage(DataflowMessageHeader, ITargetBlock<TOutput>)

Aangeroepen door een gekoppeld om ITargetBlock<TInput> een eerder aangeboden door dit DataflowMessageHeaderte ISourceBlock<TOutput> reserveren .

(Overgenomen van ISourceBlock<TOutput>)

Extensiemethoden

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

Hiermee maakt u een nieuwe IObservable<T> abstractie over de ISourceBlock<TOutput>.

AsObserver<TInput>(ITargetBlock<TInput>)

Hiermee maakt u een nieuwe IObserver<T> abstractie over de ITargetBlock<TInput>.

LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>, DataflowLinkOptions, Predicate<TOutput>)

Hiermee koppelt u de ISourceBlock<TOutput> opgegeven aan de opgegeven ITargetBlock<TInput> met behulp van het opgegeven filter.

LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>, Predicate<TOutput>)

Hiermee koppelt u de ISourceBlock<TOutput> opgegeven aan de opgegeven ITargetBlock<TInput> met behulp van het opgegeven filter.

LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>)

Hiermee koppelt u de ISourceBlock<TOutput> opgegeven ITargetBlock<TInput>.

OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>, CancellationToken)

Biedt een Task<TResult> die asynchroon de bron bewaakt voor beschikbare uitvoer.

OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>)

Biedt een Task<TResult> die asynchroon de bron bewaakt voor beschikbare uitvoer.

Post<TInput>(ITargetBlock<TInput>, TInput)

Hiermee plaatst u een item in de ITargetBlock<TInput>.

Receive<TOutput>(ISourceBlock<TOutput>, CancellationToken)

Synchroon ontvangt een waarde van een opgegeven bron en biedt een token om de bewerking te annuleren.

Receive<TOutput>(ISourceBlock<TOutput>, TimeSpan, CancellationToken)

Synchroon ontvangt een waarde van een opgegeven bron, waardoor een token wordt opgegeven om de bewerking te annuleren en een optioneel time-outinterval te observeren.

Receive<TOutput>(ISourceBlock<TOutput>, TimeSpan)

Synchroon ontvangt een waarde van een opgegeven bron, waarbij een optionele time-outperiode wordt waargenomen.

Receive<TOutput>(ISourceBlock<TOutput>)

Hiermee ontvangt u synchroon een waarde van een opgegeven bron.

ReceiveAsync<TOutput>(ISourceBlock<TOutput>, CancellationToken)

Asynchroon ontvangt een waarde van een opgegeven bron en biedt een token om de bewerking te annuleren.

ReceiveAsync<TOutput>(ISourceBlock<TOutput>, TimeSpan, CancellationToken)

Asynchroon ontvangt een waarde van een opgegeven bron, waarbij een token wordt opgegeven om de bewerking te annuleren en een optioneel time-outinterval te observeren.

ReceiveAsync<TOutput>(ISourceBlock<TOutput>, TimeSpan)

Asynchroon ontvangt een waarde van een opgegeven bron, waarbij een optionele time-outperiode wordt waargenomen.

ReceiveAsync<TOutput>(ISourceBlock<TOutput>)

Asynchroon ontvangt een waarde van een opgegeven bron.

SendAsync<TInput>(ITargetBlock<TInput>, TInput, CancellationToken)

Asynchroon biedt een bericht aan het doelberichtblok, waardoor uitstel mogelijk is.

SendAsync<TInput>(ITargetBlock<TInput>, TInput)

Asynchroon biedt een bericht aan het doelberichtblok, waardoor uitstel mogelijk is.

Van toepassing op