IReceivableSourceBlock<TOutput> Arabirim
Tanım
Önemli
Bazı bilgiler ürünün ön sürümüyle ilgilidir ve sürüm öncesinde önemli değişiklikler yapılmış olabilir. Burada verilen bilgilerle ilgili olarak Microsoft açık veya zımni hiçbir garanti vermez.
Bağlama olmadan ileti almayı destekleyen bir veri akışı bloğunu temsil eder.
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 IDataflowBlocktype IReceivableSourceBlock<'Output> = interface
interface IDataflowBlock
interface ISourceBlock<'Output>Public Interface IReceivableSourceBlock(Of TOutput)
Implements ISourceBlock(Of TOutput)Tür Parametreleri
- TOutput
tarafından IReceivableSourceBlock<TOutput>sağlanan veri türünü belirtir.
- Türetilmiş
- Uygulamalar
Açıklamalar
Note
TPL Veri Akışı Kitaplığı (System.Threading.Tasks.Dataflow ad alanı) .NET ile dağıtılmaz. Visual Studio'da System.Threading.Tasks.Dataflow ad alanını yüklemek için projenizi açın, Project menüsünden NuGet Paketlerini Yönet seçin ve System.Threading.Tasks.Dataflow paketini çevrimiçi olarak arayın. Alternatif olarak, .NET Core CLI kullanarakyüklemek için dotnet add package System.Threading.Tasks.Dataflowçalıştırın.
Özellikler
| Name | Description |
|---|---|
| Completion |
Zaman uyumsuz işlemi ve veri akışı bloğunun tamamlanmasını temsil eden bir Task alır. (Devralındığı yer: IDataflowBlock) |
Yöntemler
| Name | Description |
|---|---|
| Complete() |
IDataflowBlock daha fazla ileti kabul etmemesi veya üretmemesi ya da ertelenmiş iletileri kullanmaması gerektiğine dair sinyaller. (Devralındığı yer: IDataflowBlock) |
| ConsumeMessage(DataflowMessageHeader, ITargetBlock<TOutput>, Boolean) |
Bu tarafından daha önce sunulan bir ITargetBlock<TInput> öğesini kabul etmek ve kullanmak için bağlı DataflowMessageHeader tarafından çağrılırISourceBlock<TOutput>. (Devralındığı yer: ISourceBlock<TOutput>) |
| Fault(Exception) |
öğesinin IDataflowBlock bir Faulted durumda tamamlanmasını neden olur. (Devralındığı yer: IDataflowBlock) |
| LinkTo(ITargetBlock<TOutput>, DataflowLinkOptions) |
öğesini ISourceBlock<TOutput> belirtilen ITargetBlock<TInput>öğesine bağlar. (Devralındığı yer: ISourceBlock<TOutput>) |
| ReleaseReservation(DataflowMessageHeader, ITargetBlock<TOutput>) |
Daha önce bu tarafından ayrılmış ITargetBlock<TInput> bir sürümü yayınlamak için bağlı DataflowMessageHeader bir tarafından çağrılırISourceBlock<TOutput>. (Devralındığı yer: ISourceBlock<TOutput>) |
| ReserveMessage(DataflowMessageHeader, ITargetBlock<TOutput>) |
Bu tarafından daha önce sunulan bir ayırmak için bağlı ITargetBlock<TInput> tarafından çağrılır DataflowMessageHeaderISourceBlock<TOutput>. (Devralındığı yer: ISourceBlock<TOutput>) |
| TryReceive(Predicate<TOutput>, TOutput) |
öğesinden IReceivableSourceBlock<TOutput>zaman uyumlu bir şekilde kullanılabilir bir çıkış öğesi almaya çalışır. |
| TryReceiveAll(IList<TOutput>) |
öğesinden IReceivableSourceBlock<TOutput>tüm kullanılabilir öğeleri zaman uyumlu bir şekilde almaya çalışır. |
Uzantı Metotları
| Name | Description |
|---|---|
| AsObservable<TOutput>(ISourceBlock<TOutput>) |
üzerinde IObservable<T>yeni ISourceBlock<TOutput> bir soyutlama oluşturur. |
| LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>, DataflowLinkOptions, Predicate<TOutput>) |
ISourceBlock<TOutput> belirtilen filtreyi kullanarak öğesini belirtilene ITargetBlock<TInput> bağlar. |
| LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>, Predicate<TOutput>) |
ISourceBlock<TOutput> belirtilen filtreyi kullanarak öğesini belirtilene ITargetBlock<TInput> bağlar. |
| LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>) |
öğesini ISourceBlock<TOutput> belirtilen ITargetBlock<TInput>öğesine bağlar. |
| OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>, CancellationToken) |
Kaynağı kullanılabilir çıkış için zaman uyumsuz olarak izleyen bir Task<TResult> sağlar. |
| OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>) |
Kaynağı kullanılabilir çıkış için zaman uyumsuz olarak izleyen bir Task<TResult> sağlar. |
| 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, CancellationToken) |
Belirtilen kaynaktan zaman uyumlu bir şekilde bir değer alır ve işlemi iptal etmek için bir belirteç sağlar ve isteğe bağlı bir zaman aşımı aralığını gözlemler. |
| Receive<TOutput>(ISourceBlock<TOutput>, TimeSpan) |
Belirli bir kaynaktan isteğe bağlı zaman aşımı süresini gözlemleyerek zaman uyumlu bir şekilde bir değer alır. |
| Receive<TOutput>(ISourceBlock<TOutput>) |
Belirtilen kaynaktan zaman uyumlu olarak bir değer alır. |
| ReceiveAllAsync<TOutput>(IReceivableSourceBlock<TOutput>, CancellationToken) |
Kaynaktan tüm verilerin alınmasını sağlayan bir IAsyncEnumerable<T> oluşturur. |
| ReceiveAsync<TOutput>(ISourceBlock<TOutput>, CancellationToken) |
Belirli bir kaynaktan zaman uyumsuz olarak bir değer alır ve işlemi iptal etmek için bir belirteç sağlar. |
| ReceiveAsync<TOutput>(ISourceBlock<TOutput>, TimeSpan, CancellationToken) |
Belirli bir kaynaktan zaman uyumsuz olarak bir değer alır ve işlemi iptal etmek için bir belirteç sağlar ve isteğe bağlı bir zaman aşımı aralığını gözlemler. |
| ReceiveAsync<TOutput>(ISourceBlock<TOutput>, TimeSpan) |
İsteğe bağlı zaman aşımı süresini gözlemleyerek belirtilen kaynaktan zaman uyumsuz olarak bir değer alır. |
| ReceiveAsync<TOutput>(ISourceBlock<TOutput>) |
Belirtilen kaynaktan zaman uyumsuz olarak bir değer alır. |
| TryReceive<TOutput>(IReceivableSourceBlock<TOutput>, TOutput) |
öğesinden ISourceBlock<TOutput>bir öğeyi zaman uyumlu bir şekilde almaya çalışır. |
