ISourceBlock<TOutput> Arabirim

Tanım

Ad Alanı:

System.Threading.Tasks.Dataflow

Bütünleştirilmiş Kod:

System.Threading.Tasks.Dataflow.dll

Paket:

System.Threading.Tasks.Dataflow v9.0.0-preview.4.24266.19

Veri kaynağı olan bir veri akışı bloğunu temsil eder.

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

Tür Parametreleri

TOutput

tarafından ISourceBlock<TOutput>sağlanan veri türünü belirtir.

Bu genel tür parametresi kovaryanttır. Bu, kendi belirttiğiniz türü veya daha fazla türetilmiş başka bir türü kullanabileceğiniz anlamına gelir. Kovaryans ve kontravaryans hakkında daha fazla bilgi için bkz. Genel Türlerde Kovaryans ve Kontravaryans.

Türetilmiş

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>

Uygulamalar

IDataflowBlock

Açıklamalar

Not

TPL Veri Akışı Kitaplığı ( System.Threading.Tasks.Dataflow ad alanı) .NET ile dağıtılmaz. Ad alanını System.Threading.Tasks.Dataflow Visual Studio'ya yüklemek için projenizi açın, Projemenüsünden NuGet Paketlerini Yönet'i seçin ve çevrimiçi ortamda paketi arayınSystem.Threading.Tasks.Dataflow. Alternatif olarak, .NET Core CLI kullanarak yüklemek için komutunu çalıştırın dotnet add package System.Threading.Tasks.Dataflow.

Özellikler

Completion

Zaman uyumsuz işlemi ve veri akışı bloğunun tamamlanmasını temsil eden bir Task alır. (Devralındığı yer: IDataflowBlock)

Yöntemler

Complete()	IDataflowBlock daha fazla ileti kabul etmemesi, üretmemesi veya ertelenmiş iletileri tüketmemesi gerektiğine dair sinyaller. (Devralındığı yer: IDataflowBlock)
ConsumeMessage(DataflowMessageHeader, ITargetBlock<TOutput>, Boolean)	Bu tarafından daha önce sunulan bir kabul etmek ve kullanmak için bağlı ITargetBlock<TInput>DataflowMessageHeader tarafından çağrılır ISourceBlock<TOutput>.
Fault(Exception)	bir IDataflowBlock durumda Faulted tamamlanmasına neden olur. (Devralındığı yer: IDataflowBlock)
LinkTo(ITargetBlock<TOutput>, DataflowLinkOptions)	öğesini ISourceBlock<TOutput> belirtilen ITargetBlock<TInput>öğesine bağlar.
ReleaseReservation(DataflowMessageHeader, ITargetBlock<TOutput>)	Bu tarafından daha önce ayrılmış DataflowMessageHeader bir sürümü yayınlamak için bağlı ITargetBlock<TInput> tarafından çağrılırISourceBlock<TOutput>.
ReserveMessage(DataflowMessageHeader, ITargetBlock<TOutput>)	Daha önce bu tarafından sunulan bir ayırmak için bağlı ITargetBlock<TInput> tarafından çağrılır DataflowMessageHeaderISourceBlock<TOutput>.

Uzantı Metotları

AsObservable<TOutput>(ISourceBlock<TOutput>)	üzerinde ISourceBlock<TOutput>yeni IObservable<T> bir soyutlama oluşturur.
LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>)	öğesini ISourceBlock<TOutput> belirtilen ITargetBlock<TInput>öğesine bağlar.
LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>, Predicate<TOutput>)	ISourceBlock<TOutput> Belirtilen filtreyi kullanarak öğesini belirtilen ITargetBlock<TInput> öğesine bağlar.
LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>, DataflowLinkOptions, Predicate<TOutput>)	ISourceBlock<TOutput> Belirtilen filtreyi kullanarak öğesini belirtilen ITargetBlock<TInput> öğesine bağlar.
OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>)	Kaynağı kullanılabilir çıktı için zaman uyumsuz olarak izleyen bir Task<TResult> sağlar.
OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>, CancellationToken)	Kaynağı kullanılabilir çıktı için zaman uyumsuz olarak izleyen bir Task<TResult> sağlar.
Receive<TOutput>(ISourceBlock<TOutput>)	Belirtilen kaynaktan zaman uyumlu olarak bir değer alır.
Receive<TOutput>(ISourceBlock<TOutput>, CancellationToken)	Belirtilen kaynaktan zaman uyumlu olarak bir değer alır ve işlemi iptal etmek için bir belirteç sağlar.
Receive<TOutput>(ISourceBlock<TOutput>, TimeSpan)	İsteğe bağlı zaman aşımı süresini gözlemleyerek belirtilen kaynaktan bir değeri zaman uyumlu olarak alır.
Receive<TOutput>(ISourceBlock<TOutput>, TimeSpan, CancellationToken)	Belirtilen kaynaktan zaman uyumlu olarak bir değer alır, işlemi iptal etmek için bir belirteç sağlar ve isteğe bağlı bir zaman aşımı aralığı gözlemler.
ReceiveAsync<TOutput>(ISourceBlock<TOutput>)	Belirtilen kaynaktan zaman uyumsuz olarak bir değer alır.
ReceiveAsync<TOutput>(ISourceBlock<TOutput>, CancellationToken)	Zaman uyumsuz olarak belirtilen kaynaktan bir değer alır ve işlemi iptal etmek için bir belirteç sağlar.
ReceiveAsync<TOutput>(ISourceBlock<TOutput>, TimeSpan)	Belirli bir kaynaktan zaman uyumsuz olarak bir değer alır ve isteğe bağlı bir zaman aşımı süresi gözlemler.
ReceiveAsync<TOutput>(ISourceBlock<TOutput>, TimeSpan, CancellationToken)	Belirtilen kaynaktan zaman uyumsuz olarak bir değer alır, işlemi iptal etmek için bir belirteç sağlar ve isteğe bağlı bir zaman aşımı aralığı gözlemler.