ISourceBlock<TOutput> Interface

Definitie

Naamruimte:
System.Threading.Tasks.Dataflow
Assembly:
System.Threading.Tasks.Dataflow.dll
Pakket:
System.Threading.Tasks.Dataflow v11.0.0-preview.4.26230.115
Bron:
ISourceBlock.cs
Bron:
ISourceBlock.cs
Bron:
ISourceBlock.cs
Bron:
ActionBlock.cs

Vertegenwoordigt een gegevensstroomblok dat een gegevensbron is.

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

Type parameters

TOutput

Hiermee geeft u het type gegevens op dat door de ISourceBlock<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
IDataflowBlock

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.
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>.
ReleaseReservation(DataflowMessageHeader, ITargetBlock<TOutput>)

Aangeroepen door een gekoppeld om ITargetBlock<TInput> een eerder gereserveerde DataflowMessageHeaderISourceBlock<TOutput>versie vrij te geven.
ReserveMessage(DataflowMessageHeader, ITargetBlock<TOutput>)

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

Extensiemethoden

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

Hiermee maakt u een nieuwe IObservable<T> abstractie over de ISourceBlock<TOutput>.
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.
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.

Van toepassing op