IReceivableSourceBlock<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:
IReceivableSourceBlock.cs
Bron:
IReceivableSourceBlock.cs
Bron:
IReceivableSourceBlock.cs
Bron:
DataflowMessageHeader.cs

Vertegenwoordigt een gegevensstroomblok dat ondersteuning biedt voor het ontvangen van berichten zonder koppeling.

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)

Type parameters

TOutput

Hiermee geeft u het type gegevens op dat door de IReceivableSourceBlock<TOutput>.

Afgeleid
Implementeringen
IDataflowBlock ISourceBlock<TOutput>

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>)
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>)
TryReceive(Predicate<TOutput>, TOutput)

Pogingen om synchroon een beschikbaar uitvoeritem van de IReceivableSourceBlock<TOutput>.
TryReceiveAll(IList<TOutput>)

Pogingen om alle beschikbare items synchroon te ontvangen van de IReceivableSourceBlock<TOutput>.

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.
ReceiveAllAsync<TOutput>(IReceivableSourceBlock<TOutput>, CancellationToken)

Hiermee maakt u een IAsyncEnumerable<T> bestand waarmee alle gegevens van de bron kunnen worden ontvangen.
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.
TryReceive<TOutput>(IReceivableSourceBlock<TOutput>, TOutput)

Pogingen om een item synchroon te ontvangen van de ISourceBlock<TOutput>.

Van toepassing op