ISubject<TSource, TResult> Arabirimi
Hem gözlemlenebilir bir dizi hem de gözlemci olan bir nesneyi temsil eder.
Ad Alanı:System.Reactive.Subjects
Derleme: System.Reactive (System.Reactive.dll içinde)
Syntax
'Declaration
Public Interface ISubject(Of In TSource, Out TResult) _
Inherits IObserver(Of TSource), IObservable(Of TResult)
'Usage
Dim instance As ISubject(Of In TSource, Out TResult)
public interface ISubject<in TSource, out TResult> : IObserver<TSource>,
IObservable<TResult>
generic<typename TSource, typename TResult>
public interface class ISubject : IObserver<TSource>,
IObservable<TResult>
type ISubject<'TSource, 'TResult> =
interface
interface IObserver<'TSource>
interface IObservable<'TResult>
end
JScript does not support generic types and methods.
Tür Parametreleri
inTSource
Kaynak türü.Bu genel tür parametresi kontravaryanttır. Bu, kendi belirttiğiniz türü veya daha az türetilmiş başka bir türü kullanabileceğiniz anlamına gelir. Kovaryans ve kontravaryans hakkında daha fazla bilgi için bkz . .
outTResult
Sonucun türü.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 . .
ISubject<TSource, TResult> türü aşağıdaki üyeleri kullanıma sunar.
Yöntemler
| Ad | Açıklama | |
|---|---|---|
.gif "Public yöntemi") |
Oncompleted | ( IObserver'dan< devralındıTSource>.) |
|
OnError | ( IObserver'dan< devralındıTSource>.) |
|
Onnext | ( IObserver'dan< devralındıTSource>.) |
|
Abonelik | ( IObservable'dan devralındı<TResult>.) |
Üst
Uzantı Metotları
| Ad | Açıklama | |
|---|---|---|
.gif "Genel Uzantı Yöntemi") |
Toplama<TResult>(Func<TResult, TResult, TResult>) | Fazla Yüklendi. Gözlemlenebilir bir dizi üzerinde bir akümülatör işlevi uygular. ( Gözlemlenebilir tarafından tanımlanır.) |
|
Toplama<TResult, TAccumulate>(TAccumulate, Func<TAccumulate, TResult, TAccumulate>) | Fazla Yüklendi. Belirtilen çekirdek değerine sahip gözlemlenebilir bir dizi üzerinde bir biriktirici işlevi uygular. ( Gözlemlenebilir tarafından tanımlanır.) |
|
Tüm<TResult> | Gözlemlenebilir bir dizinin tüm öğelerinin bir koşulu karşılayıp karşılamayacağını belirler. ( Gözlemlenebilir tarafından tanımlanır.) |
|
Amb<TResult> | Belirtilen birinci ve ikinci diziyle ilk tepki veren gözlemlenebilir diziyi yayılım. ( Gözlemlenebilir tarafından tanımlanır.) |
|
Ve<TResult, TRight> | Her iki gözlemlenebilir dizide de kullanılabilir bir değer olduğunda eşleşir. ( Gözlemlenebilir tarafından tanımlanır.) |
|
Herhangi bir<TResult>() | Fazla Yüklendi. Gözlemlenebilir bir dizinin herhangi bir öğe içerip içermediğini belirler. ( Gözlemlenebilir tarafından tanımlanır.) |
|
Herhangi bir<TResult>(Func<TResult, Boole)> | Fazla Yüklendi. Gözlemlenebilir bir dizinin tüm öğelerinin bir koşulu karşılayıp karşılamayacağını belirler. ( Gözlemlenebilir tarafından tanımlanır.) |
|
AsObservable<TResult> | Gözlemlenebilir bir dizinin kimliğini gizler. ( Gözlemlenebilir tarafından tanımlanır.) |
|
AsObserver<TSource> | Bir gözlemcinin kimliğini gizler. ( Gözlemci tarafından tanımlanır.) |
|
AsQbservable<TResult> | Gözlemlenebilir bir diziyi sorgulanabilir gözlemlenebilir bir diziye dönüştürür. ( Qbservable tarafından tanımlanır.) |
|
AssertEqual<TResult> | ( Uzantılar tarafından tanımlanır.) |
|
Arabellek<TResult>(Int32) | Fazla Yüklendi. Gözlemlenebilir bir dizinin her öğesini, öğe sayısı bilgilerine göre oluşturulan ardışık çakışmayan arabelleklere gösterir. ( Gözlemlenebilir tarafından tanımlanır.) |
|
Arabellek<TResult>(TimeSpan) | Fazla Yüklendi. Gözlemlenebilir dizinin her öğesini zamanlama bilgilerine göre oluşturulan ardışık örtüşmeyen arabelleklere gösterir. ( Gözlemlenebilir tarafından tanımlanır.) |
|
Arabellek<TResult>(Int32, Int32) | Fazla Yüklendi. Gözlemlenebilir bir dizinin her öğesini, öğe sayısı bilgilerine göre oluşturulan sıfır veya daha fazla arabelleğe gösterir. ( Gözlemlenebilir tarafından tanımlanır.) |
|
Arabellek<TResult>(TimeSpan, IScheduler) | Fazla Yüklendi. Gözlemlenebilir dizinin her öğesini zamanlama bilgilerine göre oluşturulan ardışık örtüşmeyen arabelleklere gösterir. ( Gözlemlenebilir tarafından tanımlanır.) |
|
Arabellek<TResult>(TimeSpan, TimeSpan) | Fazla Yüklendi. Gözlemlenebilir dizideki her öğeyi zamanlama bilgilerine göre oluşturulan sıfır veya daha fazla arabelleğe gösterir. ( Gözlemlenebilir tarafından tanımlanır.) |
|
Arabellek<TResult>(TimeSpan, Int32) | Fazla Yüklendi. Gözlemlenebilir dizinin her öğesini, dolu olduğunda veya belirli bir süre geçtiğinde gönderilen bir arabelleğe belirtir. ( Gözlemlenebilir tarafından tanımlanır.) |
|
Arabellek<TResult>(TimeSpan, TimeSpan, IScheduler) | Fazla Yüklendi. Gözlemlenebilir dizideki her öğeyi zamanlama bilgilerine göre oluşturulan sıfır veya daha fazla arabelleğe gösterir. ( Gözlemlenebilir tarafından tanımlanır.) |
|
Arabellek<TResult>(TimeSpan, Int32, IScheduler) | Fazla Yüklendi. Gözlemlenebilir dizinin her öğesini, dolu olduğunda veya belirli bir süre geçtiğinde gönderilen bir arabelleğe belirtir. ( Gözlemlenebilir tarafından tanımlanır.) |
|
Buffer<TResult, TBufferClosing>(Func<IObservable<TBufferClosing>>) | Fazla Yüklendi. Gözlemlenebilir bir dizinin her öğesini birbirini izleyen örtüşmeyen arabelleklere gösterir. ( Gözlemlenebilir tarafından tanımlanır.) |
|
Buffer<TResult, TBufferOpening, TBufferClosing>(IObservable<TBufferOpening>, Func<TBufferOpening, IObservable<TBufferClosing>>) | Fazla Yüklendi. Sorgulanabilir gözlemlenebilir dizinin her öğesini ardışık örtüşmeyen arabelleklere gösterir. ( Gözlemlenebilir tarafından tanımlanır.) |
|
Catch<TResult>(IObservable<TResult>) | Fazla Yüklendi. Sonraki gözlemlenebilir dizi ile bir özel durum tarafından sonlandırılan gözlemlenebilir bir dizi devam eder. ( Gözlemlenebilir tarafından tanımlanır.) |
|
Catch<TResult, TException>(Func<TException, IObservable<TResult>>) | Fazla Yüklendi. İşleyici tarafından oluşturulan gözlemlenebilir dizi ile belirtilen türün özel durumu tarafından sonlandırılan gözlemlenebilir bir dizi devam eder. ( Gözlemlenebilir tarafından tanımlanır.) |
|
En Son<TResult, TSecond, TResult birleştirme> | Gözlemlenebilir dizilerden biri bir öğe oluşturduğunda seçici işlevini kullanarak iki gözlemlenebilir diziyi tek bir gözlemlenebilir dizide birleştirir. ( Gözlemlenebilir tarafından tanımlanır.) |
|
Concat<TResult> | İki gözlemlenebilir diziyi birleştirir. ( Gözlemlenebilir tarafından tanımlanır.) |
|
TResult>(TResult) içerir< | Fazla Yüklendi. Varsayılan eşitlik karşılaştırıcısını kullanarak gözlemlenebilir bir dizinin belirtilen bir öğeyi içerip içermediğini belirler. ( Gözlemlenebilir tarafından tanımlanır.) |
|
TResult>(TResult, IEqualityComparer<TResult>) içerir< | Fazla Yüklendi. Belirtilen System.Collections.Generic.IEqualityComparer< kullanarak gözlemlenebilir bir dizinin belirtilen bir öğeyi içerip içermediğini belirler; T>. ( Gözlemlenebilir tarafından tanımlanır.) |
|
TResult Sayısı<> | Gözlemlenebilir bir dizideki öğelerin toplam sayısını temsil eden bir Int32 döndürür. ( Gözlemlenebilir tarafından tanımlanır.) |
|
DefaultIfEmpty<TResult>() | Fazla Yüklendi. Belirtilen dizinin öğelerini veya dizi boşsa tür parametresinin varsayılan değerini tek bir dizide döndürür. ( Gözlemlenebilir tarafından tanımlanır.) |
|
DefaultIfEmpty<TResult>(TResult) | Fazla Yüklendi. Belirtilen dizinin öğelerini veya dizi boşsa tür parametresinin varsayılan değerini tek bir dizide döndürür. ( Gözlemlenebilir tarafından tanımlanır.) |
|
Gecikme<TResult>(TimeSpan) | Fazla Yüklendi. Belirtilen kaynak ve dueTime ile vadesine göre gözlemlenebilir sırayı gösterir. ( Gözlemlenebilir tarafından tanımlanır.) |
|
Gecikme<TResult>(DateTimeOffset) | Fazla Yüklendi. Belirtilen kaynak ve dueTime ile vadesine göre gözlemlenebilir sırayı gösterir. ( Gözlemlenebilir tarafından tanımlanır.) |
|
Delay<TResult>(TimeSpan, IScheduler) | Fazla Yüklendi. Belirtilen kaynak, dueTime ve scheduler ile vadesine göre gözlemlenebilir sırayı gösterir. ( Gözlemlenebilir tarafından tanımlanır.) |
|
Delay<TResult>(DateTimeOffset, IScheduler) | Fazla Yüklendi. Belirtilen kaynak, dueTime ve scheduler ile vadesine göre gözlemlenebilir sırayı gösterir. ( Gözlemlenebilir tarafından tanımlanır.) |
|
Distinct<TResult>() | Fazla Yüklendi. Yalnızca belirli bir kaynağa sahip ayrı öğeler içeren gözlemlenebilir bir dizi döndürür. ( Gözlemlenebilir tarafından tanımlanır.) |
|
Distinct<TResult>(IEqualityComparer<TResult>) | Fazla Yüklendi. Karşılaştırıcıya göre yalnızca ayrı öğeler içeren gözlemlenebilir bir dizi döndürür. ( Gözlemlenebilir tarafından tanımlanır.) |
|
Distinct<TResult, TKey>(Func<TResult, TKey>) | Fazla Yüklendi. yalnızca keySelector'a göre ayrı öğeler içeren gözlemlenebilir bir dizi döndürür. ( Gözlemlenebilir tarafından tanımlanır.) |
|
Distinct<TResult, TKey>(Func<TResult, TKey>, IEqualityComparer<TKey>) | Fazla Yüklendi. yalnızca keySelector'a göre ayrı öğeler içeren gözlemlenebilir bir dizi döndürür. ( Gözlemlenebilir tarafından tanımlanır.) |
|
DistinctUntilChanged<TResult>() | Fazla Yüklendi. Yalnızca belirli bir kaynağa sahip ayrı bitişik öğeler içeren gözlemlenebilir bir dizi döndürür. ( Gözlemlenebilir tarafından tanımlanır.) |
|
DistinctUntilChanged<TResult>(IEqualityComparer<TResult>) | Fazla Yüklendi. Karşılaştırıcıya göre yalnızca ayrı bitişik öğeler içeren gözlemlenebilir bir dizi döndürür. ( Gözlemlenebilir tarafından tanımlanır.) |
|
DistinctUntilChanged<TResult, TKey>(Func<TResult, TKey>) | Fazla Yüklendi. yalnızca keySelector'a göre ayrı bitişik öğeler içeren gözlemlenebilir bir dizi döndürür. ( Gözlemlenebilir tarafından tanımlanır.) |
|
DistinctUntilChanged<TResult, TKey>(Func<TResult, TKey>, IEqualityComparer<TKey>) | Fazla Yüklendi. keySelector ve karşılaştırıcıya göre yalnızca ayrı bitişik öğeler içeren gözlemlenebilir bir dizi döndürür. ( Gözlemlenebilir tarafından tanımlanır.) |
|
Do<TResult>(Eylem<TResult>) | Fazla Yüklendi. Gözlemlenebilir dizideki her öğe için bir eylem çağırır. ( Gözlemlenebilir tarafından tanımlanır.) |
|
Do<TResult>(IObserver<TResult>) | Fazla Yüklendi. Gözlemlenebilir dizideki her öğe için bir eylem çağırır ve gözlemlenebilir dizinin olağanüstü sonlandırılması üzerine bir eylem çağırır. ( Gözlemlenebilir tarafından tanımlanır.) |
|
Do<TResult>(Action<TResult>, Action) | Fazla Yüklendi. Gözlemlenebilir dizideki her öğe için bir eylem çağırır ve gözlemlenebilir dizi düzgün sonlandırılırken bir eylem çağırır. ( Gözlemlenebilir tarafından tanımlanır.) |
|
Do<TResult>(Eylem<TResult>, Eylem<Özel Durumu>) | Fazla Yüklendi. Gözlemlenebilir dizideki her öğe için bir eylem çağırır ve gözlemlenebilir dizinin olağanüstü sonlandırılması üzerine bir eylem çağırır. ( Gözlemlenebilir tarafından tanımlanır.) |
|
Do<TResult>(Eylem<TResult>, Eylem<Özel Durumu>, Eylem) | Fazla Yüklendi. Gözlemlenebilir dizideki her öğe için bir eylem çağırır ve gözlemlenebilir dizinin düzgün veya istisnai şekilde sonlandırılmasına ilişkin bir eylem çağırır. ( Gözlemlenebilir tarafından tanımlanır.) |
|
ElementAt<TResult> | Bir dizideki belirtilen dizindeki öğesini döndürür. ( Gözlemlenebilir tarafından tanımlanır.) |
|
ElementAtOrDefault<TResult> | Belirtilen dizindeki öğeyi bir dizide veya dizin aralık dışındaysa varsayılan bir değerle döndürür. ( Gözlemlenebilir tarafından tanımlanır.) |
|
Son olarak<TResult> | Kaynak gözlemlenebilir dizisi normal olarak veya bir özel durum tarafından sonlandırıldıktan sonra belirtilen eylemi çağırır. ( Gözlemlenebilir tarafından tanımlanır.) |
|
İlk<TResult>() | Fazla Yüklendi. Belirtilen kaynağa sahip gözlemlenebilir bir dizinin ilk öğesini döndürür. ( Gözlemlenebilir tarafından tanımlanır.) |
|
first<TResult>(Func<TResult, Boolean>) | Fazla Yüklendi. Koşulla eşleşen gözlemlenebilir bir dizinin ilk öğesini döndürür. ( Gözlemlenebilir tarafından tanımlanır.) |
|
FirstOrDefault<TResult>() | Fazla Yüklendi. Gözlemlenebilir bir dizinin ilk öğesini veya değer bulunamazsa varsayılan değeri döndürür. ( Gözlemlenebilir tarafından tanımlanır.) |
|
FirstOrDefault<TResult>(Func<TResult, Boolean>) | Fazla Yüklendi. Koşulla eşleşen gözlemlenebilir bir dizinin ilk öğesini veya değer bulunamazsa varsayılan değeri döndürür. ( Gözlemlenebilir tarafından tanımlanır.) |
|
Foo<TResult, R> | ( MyExt tarafından tanımlanır.) |
|
ForEach<TResult> | Gözlemlenebilir dizideki her öğe için bir eylem çağırır ve dizi sonlandırılana kadar engeller. ( Gözlemlenebilir tarafından tanımlanır.) |
|
GetEnumerator<TResult> | Gözlemlenebilir dizinin tüm değerlerini numaralandıran bir numaralandırıcı döndürür. ( Observable tarafından tanımlanır.) |
|
GroupBy<TResult, TKey>(Func<TResult, TKey>) | Fazla Yüklendi. Gözlemlenebilir bir dizinin öğelerini belirtilen anahtar seçici işlevine göre gruplandırın. ( Observable tarafından tanımlanır.) |
|
GroupBy<TResult, TKey>(Func<TResult, TKey>, IEqualityComparer<TKey>) | Fazla Yüklendi. Gözlemlenebilir bir dizinin öğelerini belirtilen anahtar seçici işlevine ve karşılaştırıcıya göre gruplandırır. ( Observable tarafından tanımlanır.) |
|
GroupBy<TResult, TKey, TElement>(Func<TResult, TKey>, Func<TResult, TElement>) | Fazla Yüklendi. Gözlemlenebilir bir dizinin öğelerini gruplandırın ve belirtilen bir işlevi kullanarak sonuçta elde edilen öğeleri seçer. ( Observable tarafından tanımlanır.) |
|
GroupBy<TResult, TKey, TElement>(Func<TResult, TKey>, Func<TResult, TElement>, IEqualityComparer<TKey>) | Fazla Yüklendi. Gözlemlenebilir bir dizinin öğelerini belirtilen anahtar seçici işlevine ve karşılaştırıcıya göre gruplandırır ve belirtilen bir işlevi kullanarak sonuçta elde edilen öğeleri seçer. ( Observable tarafından tanımlanır.) |
|
GroupByUntil<TResult, TKey, TDuration>(Func<TResult, TKey>, Func<IGroupedObservable<TKey, TResult>, IObservable<TDuration>>) | Fazla Yüklendi. Gözlemlenebilir bir dizinin öğelerini belirtilen anahtar seçici işlevine göre gruplandırın. ( Observable tarafından tanımlanır.) |
|
GroupByUntil<TResult, TKey, TDuration>(Func<TResult, TKey>, Func<IGroupedObservable<TKey, TResult>, IObservable<TDuration>>, IEqualityComparer<TKey>) | Fazla Yüklendi. Gözlemlenebilir bir dizinin öğelerini belirtilen anahtar seçici işlevine ve karşılaştırıcıya göre gruplandırır. ( Observable tarafından tanımlanır.) |
|
GroupByUntil<TResult, TKey, TElement, TDuration>(Func<TResult, TKey>, Func<TResult, TElement>, Func<IGroupedObservable<TKey, TElement>, IObservable<TDuration>>) | Fazla Yüklendi. Gözlemlenebilir bir dizinin öğelerini belirtilen bir anahtar seçici işlevine göre gruplandırın ve belirtilen bir işlevi kullanarak sonuçta elde edilen öğeleri seçer. ( Observable tarafından tanımlanır.) |
|
GroupByUntil<TResult, TKey, TElement, TDuration>(Func<TResult, TKey>, Func<TResult, TElement>, Func<IGroupedObservable<TKey, TElement>, IObservable<TDuration>>, IEqualityComparer<TKey>) | Fazla Yüklendi. Gözlemlenebilir bir dizinin öğelerini belirtilen anahtar seçici işlevine ve karşılaştırıcıya göre gruplandırır ve belirtilen bir işlevi kullanarak sonuçta elde edilen öğeleri seçer. ( Observable tarafından tanımlanır.) |
|
GroupJoin<TResult, TRight, TLeftDuration, TRightDuration, TResult> | çakışma sürelerine göre iki dizinin öğelerini ilişkilendirir ve sonuçları gruplandırın. ( Observable tarafından tanımlanır.) |
|
IgnoreElements<TResult> | Gözlemlenebilir bir dizideki tüm değerleri yoksayar ve yalnızca sonlandırma iletilerini bırakır. ( Observable tarafından tanımlanır.) |
|
Join<TResult, TRight, TLeftDuration, TRightDuration, TResult> | Çakışma sürelerine göre iki dizinin öğelerini ilişkilendirir. ( Observable tarafından tanımlanır.) |
|
Last<TResult>() | Fazla Yüklendi. Belirtilen kaynakla gözlemlenebilir bir dizinin son öğesini döndürür. ( Observable tarafından tanımlanır.) |
|
Last<TResult>(Func<TResult, Boolean>) | Fazla Yüklendi. Koşulla eşleşen gözlemlenebilir bir dizinin son öğesini döndürür. ( Observable tarafından tanımlanır.) |
|
LastOrDefault<TResult>() | Fazla Yüklendi. Gözlemlenebilir dizideki son öğeyi veya değer bulunamazsa varsayılan değeri döndürür. ( Observable tarafından tanımlanır.) |
|
LastOrDefault<TResult>(Func<TResult, Boolean>) | Fazla Yüklendi. Koşulla eşleşen gözlemlenebilir bir dizinin son öğesini veya değer bulunamazsa varsayılan değeri döndürür. ( Observable tarafından tanımlanır.) |
|
En Son<TResult> | Gözlemlenebilir bir dizideki en son değeri örnekler. ( Observable tarafından tanımlanır.) |
|
LongCount<TResult> | Gözlemlenebilir bir dizideki öğelerin toplam sayısını temsil eden bir Int64 döndürür. ( Observable tarafından tanımlanır.) |
|
TResult'un Gerçekleştirilmesi<> | Gözlemlenebilir bir dizinin örtük bildirimlerini açık bildirim değerleri olarak oluşturur. ( Observable tarafından tanımlanır.) |
|
Max<TResult>() | Fazla Yüklendi. Gözlemlenebilir bir dizideki en büyük öğeyi döndürür. ( Observable tarafından tanımlanır.) |
|
Max<TResult>(IComparer<TResult>) | Fazla Yüklendi. Belirtilen karşılaştırıcıya göre gözlemlenebilir bir dizideki en büyük değeri döndürür. ( Observable tarafından tanımlanır.) |
|
MaxBy<TResult, TKey>(Func<TResult, TKey>) | Fazla Yüklendi. En büyük anahtar değeriyle gözlemlenebilir bir dizideki öğeleri döndürür. ( Gözlemlenebilir tarafından tanımlanır.) |
|
MaxBy<TResult, TKey>(Func<TResult, TKey>, IComparer<TKey>) | Fazla Yüklendi. En büyük anahtar değeriyle gözlemlenebilir bir dizideki öğeleri döndürür. ( Gözlemlenebilir tarafından tanımlanır.) |
|
Birleştirme<TResult>(IObservable<TResult>) | Fazla Yüklendi. Gözlemlenebilir dizilerin gözlemlenebilir dizisini gözlemlenebilir bir dizide birleştirir. ( Gözlemlenebilir tarafından tanımlanır.) |
|
Birleştirme<TResult>(IObservable<TResult>, IScheduler) | Fazla Yüklendi. İki gözlemlenebilir diziyi tek bir gözlemlenebilir dizide birleştirir. ( Gözlemlenebilir tarafından tanımlanır.) |
|
Min<TResult>() | Fazla Yüklendi. Gözlemlenebilir bir dizideki en küçük öğeyi döndürür. ( Gözlemlenebilir tarafından tanımlanır.) |
|
Min<TResult>(IComparer<TResult>) | Fazla Yüklendi. Belirtilen karşılaştırıcıya göre gözlemlenebilir bir dizideki en düşük değeri döndürür. ( Gözlemlenebilir tarafından tanımlanır.) |
|
MinBy<TResult, TKey>(Func<TResult, TKey>) | Fazla Yüklendi. En düşük anahtar değeriyle gözlemlenebilir bir dizideki öğeleri döndürür. ( Gözlemlenebilir tarafından tanımlanır.) |
|
MinBy<TResult, TKey>(Func<TResult, TKey>, IComparer<TKey>) | Fazla Yüklendi. Belirtilen karşılaştırıcıya göre en düşük anahtar değeriyle gözlemlenebilir bir dizideki öğeleri döndürür. ( Gözlemlenebilir tarafından tanımlanır.) |
|
MostRecent<TResult> | Gözlemlenebilir bir dizideki en son değeri örnekler. ( Gözlemlenebilir tarafından tanımlanır.) |
|
Çok Noktaya Yayın<TResult, TResult>(ISubject<TResult, TResult>) | Fazla Yüklendi. Bağlantıdan sonra kaynak dizinin sonuçları belirtilen konuya göndermesine neden olan, bağlanabilir bir gözlemlenebilir dizi döndürür. ( Gözlemlenebilir tarafından tanımlanır.) |
|
Çok Noktaya Yayın<TResult, TIntermediate, TResult>(Func<ISubject<TResult, TIntermediate>>, Func<IObservable<TIntermediate>, IObservable<TResult>>) | Fazla Yüklendi. Bir seçici işlevi içindeki kaynak diziyi çok noktaya yayınlayarak üretilen bir dizinin öğelerini içeren gözlemlenebilir bir dizi döndürür. ( Gözlemlenebilir tarafından tanımlanır.) |
|
Sonraki<TResult> | Bir sonraki değeri (arabelleğe almadan engelleme) gözlemlenebilir bir dizide örneği. ( Gözlemlenebilir tarafından tanımlanır.) |
|
ObserveOn<TResult>(SynchronizationContext) | Fazla Yüklendi. Belirtilen eşitleme bağlamında gözlemcileri zaman uyumsuz olarak bilgilendirir. ( Gözlemlenebilir tarafından tanımlanır.) |
|
ObserveOn<TResult>(Denetim) | Fazla Yüklendi. ( ControlObservable tarafından tanımlanır.) |
|
ObserveOn<TResult>(Dispatcher) | Fazla Yüklendi. ( DispatcherObservable tarafından tanımlanır.) |
|
ObserveOn<TResult>(DispatcherScheduler) | Fazla Yüklendi. ( DispatcherObservable tarafından tanımlanır.) |
|
ObserveOn<TResult>(IScheduler) | Fazla Yüklendi. Belirtilen zamanlayıcıda gözlemcileri zaman uyumsuz olarak bilgilendirir. ( Gözlemlenebilir tarafından tanımlanır.) |
|
ObserveOnDispatcher<TResult> | ( DispatcherObservable tarafından tanımlanır.) |
|
OnErrorResumeNext<TResult> | Normal olarak veya bir sonraki gözlemlenebilir dizi ile bir özel durum tarafından sonlandırılan gözlemlenebilir bir dizi devam eder. ( Gözlemlenebilir tarafından tanımlanır.) |
|
TResult>() Yayımlama< | Fazla Yüklendi. Temel alınan diziye tek bir abonelik paylaşan bağlanabilir gözlemlenebilir bir sıra döndürür. ( Gözlemlenebilir tarafından tanımlanır.) |
|
TResult> Yayımlama<(TResult) | Fazla Yüklendi. Temel alınan diziye tek bir abonelik paylaşan ve initialValue ile başlayan bağlanabilir gözlemlenebilir bir sıra döndürür. ( Gözlemlenebilir tarafından tanımlanır.) |
|
TResult, TResult>(Func<IObservable<TResult>, IObservable<TResult>>) yayımlama< | Fazla Yüklendi. Tek bir aboneliği temel alınan diziyle paylaşan bağlanabilir gözlemlenebilir bir dizide seçiciyi çağırmanın sonucu olan gözlemlenebilir bir dizi döndürür. ( Gözlemlenebilir tarafından tanımlanır.) |
|
TResult, TResult>(Func<IObservable<TResult>, IObservable<TResult>>, TResult) yayımlama< | Fazla Yüklendi. Temel alınan diziye tek bir abonelik paylaşan ve initialValue ile başlayan bağlanabilir gözlemlenebilir bir dizi döndürür. ( Observable tarafından tanımlanır.) |
|
PublishLast<TResult>() | Fazla Yüklendi. Yalnızca son bildirimi içeren temel diziye tek bir abonelik paylaşan bağlanabilir bir gözlemlenebilir dizi döndürür. ( Observable tarafından tanımlanır.) |
|
PublishLast<TResult, TResult>(Func<IObservable<TResult>, IObservable<TResult>>) | Fazla Yüklendi. Seçiciyi, yalnızca son bildirimi içeren temel diziye tek bir aboneliği paylaşan, bağlanılabilir gözlemlenebilir bir dizide çağırmanın sonucu olan gözlemlenebilir bir dizi döndürür. ( Observable tarafından tanımlanır.) |
|
TResult>() işlemini yineleyin< | Fazla Yüklendi. Gözlemlenebilir diziyi süresiz olarak tekrarlar. ( Observable tarafından tanımlanır.) |
|
TResult>(Int32) yineleme< | Fazla Yüklendi. Gözlemlenebilir diziyi süresiz olarak tekrarlar. ( Observable tarafından tanımlanır.) |
|
Yeniden Yürütme<TResult>() | Fazla Yüklendi. Tüm bildirimleri yeniden yürüten temel diziye tek bir abonelik paylaşan bağlanabilir gözlemlenebilir bir dizi döndürür. ( Observable tarafından tanımlanır.) |
|
Replay<TResult>(TimeSpan) | Fazla Yüklendi. Pencere içindeki tüm bildirimleri yeniden yürüten temel diziye tek bir abonelik paylaşan bağlanabilir bir gözlemlenebilir dizi döndürür. ( Observable tarafından tanımlanır.) |
|
Yeniden Yürütme<TResult>(Int32) | Fazla Yüklendi. BufferSize bildirimlerini yeniden yürütme temel dizisine tek bir abonelik paylaşan bağlanabilir bir gözlemlenebilir dizi döndürür. ( Observable tarafından tanımlanır.) |
|
Yeniden Yürütme<TResult>(IScheduler) | Fazla Yüklendi. Tüm bildirimleri yeniden yürüten temel diziye tek bir abonelik paylaşan bağlanabilir gözlemlenebilir bir dizi döndürür. ( Observable tarafından tanımlanır.) |
|
Replay<TResult>(TimeSpan, IScheduler) | Fazla Yüklendi. Pencere içindeki tüm bildirimleri yeniden yürüten temel diziye tek bir abonelik paylaşan bağlanabilir bir gözlemlenebilir dizi döndürür. ( Observable tarafından tanımlanır.) |
|
Yeniden Yürütme<TResult>(Int32, IScheduler) | Fazla Yüklendi. BufferSize bildirimlerini yeniden yürütme temel dizisine tek bir abonelik paylaşan bağlanabilir bir gözlemlenebilir dizi döndürür. ( Observable tarafından tanımlanır.) |
|
Replay<TResult>(Int32, TimeSpan) | Fazla Yüklendi. BufferSize bildirimlerini pencere içinde yeniden yürütme temel alınan diziye tek bir abonelik paylaşan bağlanabilir gözlemlenebilir bir dizi döndürür. ( Observable tarafından tanımlanır.) |
|
Replay<TResult>(Int32, TimeSpan, IScheduler) | Fazla Yüklendi. BufferSize bildirimlerini pencere içinde yeniden yürütme temel alınan diziye tek bir abonelik paylaşan bağlanabilir gözlemlenebilir bir dizi döndürür. ( Observable tarafından tanımlanır.) |
|
Replay<TResult, TResult>(Func<IObservable<TResult>, IObservable<TResult>>) | Fazla Yüklendi. Temel alınan diziye tek bir abonelik paylaşan ve ilk değerle başlayan bağlanılabilir gözlemlenebilir bir dizide seçiciyi çağırmanın sonucu olan gözlemlenebilir bir dizi döndürür. ( Observable tarafından tanımlanır.) |
|
Replay<TResult, TResult>(Func<IObservable<TResult>, IObservable<TResult>>, IScheduler) | Fazla Yüklendi. Tüm bildirimleri yeniden yürüten temel diziye tek bir abonelik paylaşan bağlanılabilir gözlemlenebilir bir dizide seçiciyi çağırmanın sonucu olan gözlemlenebilir bir dizi döndürür. ( Observable tarafından tanımlanır.) |
|
Replay<TResult, TResult>(Func<IObservable<TResult>, IObservable<TResult>>, TimeSpan) | Fazla Yüklendi. Tek bir aboneliği temel alınan diziyle paylaşan ve pencere içindeki tüm bildirimleri yeniden yürüten bağlanılabilir bir gözlemlenebilir dizide seçiciyi çağırmanın sonucu olan gözlemlenebilir bir dizi döndürür. ( Observable tarafından tanımlanır.) |
|
Replay<TResult, TResult>(Func<IObservable<TResult>, IObservable<TResult>>, Int32) | Fazla Yüklendi. BufferSize bildirimlerini yeniden yürüten temel diziye tek bir abonelik paylaşan bağlanılabilir gözlemlenebilir bir dizide seçiciyi çağırmanın sonucu olan gözlemlenebilir bir dizi döndürür. ( Observable tarafından tanımlanır.) |
|
Replay<TResult, TResult>(Func<IObservable<TResult>, IObservable<TResult>>, TimeSpan, IScheduler) | Fazla Yüklendi. Tek bir aboneliği temel alınan diziyle paylaşan ve pencere içindeki tüm bildirimleri yeniden yürüten bağlanılabilir bir gözlemlenebilir dizide seçiciyi çağırmanın sonucu olan gözlemlenebilir bir dizi döndürür. ( Observable tarafından tanımlanır.) |
|
Replay<TResult, TResult>(Func<IObservable<TResult>, IObservable<TResult>>, Int32, IScheduler) | Fazla Yüklendi. BufferSize bildirimlerini yeniden yürüten temel diziye tek bir abonelik paylaşan bağlanılabilir gözlemlenebilir bir dizide seçiciyi çağırmanın sonucu olan gözlemlenebilir bir dizi döndürür. ( Observable tarafından tanımlanır.) |
|
Replay<TResult, TResult>(Func<IObservable<TResult>, IObservable<TResult>>, Int32, TimeSpan) | Fazla Yüklendi. Tek bir aboneliği temel alınan diziyle paylaşan bağlanılabilir bir gözlemlenebilir dizide seçiciyi çağırmanın sonucu olan gözlemlenebilir bir dizi döndürür. BufferSize bildirimleri pencere içinde yeniden yürütebilirsiniz. ( Observable tarafından tanımlanır.) |
|
Replay<TResult, TResult>(Func<IObservable<TResult>, IObservable<TResult>>, Int32, TimeSpan, IScheduler) | Fazla Yüklendi. Tek bir aboneliği temel alınan diziyle paylaşan bağlanılabilir bir gözlemlenebilir dizide seçiciyi çağırmanın sonucu olan gözlemlenebilir bir dizi döndürür. BufferSize bildirimleri pencere içinde yeniden yürütebilirsiniz. ( Observable tarafından tanımlanır.) |
|
TResult>() öğesini yeniden deneyin< | Fazla Yüklendi. Kaynak gözlemlenebilir sırasını başarıyla sonlandırana kadar yineler. ( Observable tarafından tanımlanır.) |
|
Yeniden Deneme<TResult>(Int32) | Fazla Yüklendi. Kaynak gözlemlenebilir sırasını başarıyla sonlandırana kadar yineler. ( Observable tarafından tanımlanır.) |
|
Örnek<TResult>(TimeSpan) | Fazla Yüklendi. Her aralıkta gözlemlenebilir diziyi örnekler. ( Observable tarafından tanımlanır.) |
|
Örnek<TResult>(TimeSpan, IScheduler) | Fazla Yüklendi. Belirtilen kaynak, aralık ve zamanlayıcı ile her aralıkta gözlemlenebilir diziyi örnekler. ( Observable tarafından tanımlanır.) |
|
Örnek<TResult, TSample>(IObservable<TSample>) | Fazla Yüklendi. Belirtilen kaynak ve örnekleyici ile örnekleme değerlerinde gözlemlenebilir diziyi örnekler. ( Observable tarafından tanımlanır.) |
|
TResult>(Func<TResult, TResult, TResult>) tarama< | Fazla Yüklendi. Gözlemlenebilir bir dizi üzerinde bir biriktirici işlevi uygular ve belirtilen kaynak ve biriktirici ile her ara sonucu döndürür. ( Observable tarafından tanımlanır.) |
|
TResult<, TAccumulate>(TAccumulate, Func<TAccumulate, TResult, TAccumulate>) | Fazla Yüklendi. Gözlemlenebilir bir dizi üzerinde bir akümülatör işlevi uygular ve her ara sonucu belirtilen kaynak, çekirdek ve biriktirici ile döndürür. ( Observable tarafından tanımlanır.) |
|
TResult, TResult>(Func<TResult, TResult>) öğesini seçin< | Fazla Yüklendi. Gözlemlenebilir bir dizinin her öğesini belirtilen kaynak ve seçiciyle yeni bir forma projeler. ( Observable tarafından tanımlanır.) |
|
TResult, TResult>(Func<TResult, Int32, TResult>) öğesini seçin< | Fazla Yüklendi. Öğenin dizinini belirtilen kaynak ve seçiciyle birleştirerek gözlemlenebilir bir dizinin her öğesini yeni bir forma projeler. ( Observable tarafından tanımlanır.) |
|
SelectMany<TResult, TOther>(IObservable<TOther>) | Fazla Yüklendi. Gözlemlenebilir dizideki her öğeyi gözlemlenebilir bir diziye projeler ve elde edilen gözlemlenebilir dizileri tek bir gözlemlenebilir dizide düzleştirir. ( Observable tarafından tanımlanır.) |
|
SelectMany<TResult, TResult>(Func<TResult, IObservable<TResult>>) | Fazla Yüklendi. Gözlemlenebilir dizideki her öğeyi gözlemlenebilir bir diziye projeler ve elde edilen gözlemlenebilir dizileri tek bir gözlemlenebilir dizide düzleştirir. ( Observable tarafından tanımlanır.) |
|
SelectMany<TResult, TResult>(Func<TResult, IEnumerable<TResult>>) | Fazla Yüklendi. Gözlemlenebilir dizideki her öğeyi gözlemlenebilir bir diziye projeler ve elde edilen gözlemlenebilir dizileri tek bir gözlemlenebilir dizide düzleştirir. ( Observable tarafından tanımlanır.) |
|
SelectMany<TResult, TResult>(Func<TResult, IObservable<TResult>>, Func<Exception, IObservable<TResult>>, Func<IObservable<TResult>>) | Fazla Yüklendi. Gözlemlenebilir dizideki her öğeyi gözlemlenebilir bir diziye projeler ve elde edilen gözlemlenebilir dizileri tek bir gözlemlenebilir dizide düzleştirir. ( Observable tarafından tanımlanır.) |
|
SelectMany<TResult, TCollection, TResult>(Func<TResult, IEnumerable<TCollection>>, Func<TResult, TCollection, TResult>) | Fazla Yüklendi. Gözlemlenebilir dizideki her öğeyi gözlemlenebilir bir diziye projeler ve elde edilen gözlemlenebilir dizileri tek bir gözlemlenebilir dizide düzleştirir. ( Observable tarafından tanımlanır.) |
|
SelectMany<TResult, TCollection, TResult>(Func<TResult, IObservable<TCollection>>, Func<TResult, TCollection, TResult>) | Fazla Yüklendi. Gözlemlenebilir dizideki her öğeyi gözlemlenebilir bir diziye projeler ve elde edilen gözlemlenebilir dizileri tek bir gözlemlenebilir dizide düzleştirir. ( Observable tarafından tanımlanır.) |
|
SequenceEqual<TResult>(IObservable<TResult>) | Fazla Yüklendi. öğeleri çift yönlü karşılaştırarak iki dizi eşit olup olmadığını belirler. ( Observable tarafından tanımlanır.) |
|
SequenceEqual<TResult>(IObservable<TResult>, IEqualityComparer<TResult>) | Fazla Yüklendi. Belirtilen bir eşitlik karşılaştırıcısı kullanarak öğeleri çift yönlü karşılaştırarak iki sıranın eşit olup olmadığını belirler. ( Observable tarafından tanımlanır.) |
|
Tek<TResult>() | Fazla Yüklendi. Gözlemlenebilir bir dizinin tek öğesini döndürür ve gözlemlenebilir dizide tam olarak bir öğe yoksa bir özel durum oluşturur. ( Observable tarafından tanımlanır.) |
|
Tek<TResult>(Func<TResult, Boole)> | Fazla Yüklendi. Koşulla eşleşen gözlemlenebilir bir dizinin tek öğesini döndürür ve gözlemlenebilir dizide tam olarak bir öğe yoksa bir özel durum oluşturur. ( Observable tarafından tanımlanır.) |
|
SingleOrDefault<TResult>() | Fazla Yüklendi. Gözlemlenebilir bir dizinin tek öğesini veya gözlemlenebilir dizi boşsa varsayılan değeri döndürür. ( Observable tarafından tanımlanır.) |
|
SingleOrDefault<TResult>(Func<TResult, Boolean>) | Fazla Yüklendi. Koşulla eşleşen gözlemlenebilir bir dizinin tek öğesini veya değer bulunamazsa varsayılan değeri döndürür. ( Observable tarafından tanımlanır.) |
|
TResult atla<> | Gözlemlenebilir bir dizide belirtilen sayıda değeri atlar ve sonra kalan değerleri döndürür. ( Observable tarafından tanımlanır.) |
|
SkipLast<TResult> | Gözlemlenebilir bir sıranın sonunda belirtilen sayıda öğeyi atlar. ( Observable tarafından tanımlanır.) |
|
SkipUntil<TResult, TOther> | Kaynak gözlemlenebilir dizideki değerleri yalnızca diğer gözlemlenebilir dizi bir değer ürettikten sonra döndürür. ( Observable tarafından tanımlanır.) |
|
SkipWhile<TResult>(Func<TResult, Boolean>) | Fazla Yüklendi. Belirtilen koşul true olduğu sürece gözlemlenebilir bir dizideki değerleri atlar ve ardından kalan değerleri döndürür. ( Observable tarafından tanımlanır.) |
|
SkipWhile<TResult>(Func<TResult, Int32, Boolean>) | Fazla Yüklendi. Belirtilen koşul true olduğu sürece gözlemlenebilir bir dizideki değerleri atlar ve ardından kalan değerleri döndürür. ( Observable tarafından tanımlanır.) |
|
StartWith<TResult>TResult[]) | Fazla Yüklendi. Belirtilen kaynak ve değerlerle bir değer dizisini gözlemlenebilir bir diziye ekler. ( Observable tarafından tanımlanır.) |
|
StartWith<TResult>(IScheduler, TResult[]) | Fazla Yüklendi. Belirtilen kaynak, zamanlayıcı ve değerlerle bir değer dizisini gözlemlenebilir bir diziye ekler. ( Observable tarafından tanımlanır.) |
|
TResult>() abonesi<olma | Fazla Yüklendi. Gözlemlenebilir diziyi belirtilen bir kaynakla değerlendirir. ( ObservableExtensions tarafından tanımlanır.) |
|
Subscribe<TResult>(Action<TResult>) | Fazla Yüklendi. Bir öğe işleyicisini gözlemlenebilir bir diziye abone eder. ( ObservableExtensions tarafından tanımlanır.) |
|
Subscribe<TResult>(Eylem<TResult>, Eylem<Özel Durumu>) | Fazla Yüklendi. Bir öğe işleyicisini ve özel durum işleyicisini gözlemlenebilir bir diziye abone eder. ( ObservableExtensions tarafından tanımlanır.) |
|
Subscribe<TResult>(Action<TResult>, Action) | Fazla Yüklendi. Bir öğe işleyicisini ve tamamlama işleyicisini gözlemlenebilir bir diziye abone eder. ( ObservableExtensions tarafından tanımlanır.) |
|
Subscribe<TResult>(Eylem<TResult>, Eylem<Özel Durumu>, Eylem) | Fazla Yüklendi. Bir öğe işleyicisini, özel durum işleyicisini ve tamamlama işleyicisini gözlemlenebilir bir diziye abone eder. ( ObservableExtensions tarafından tanımlanır.) |
|
SubscribeOn<TResult>(SynchronizationContext) | Fazla Yüklendi. Zaman uyumsuz olarak belirtilen eşitleme bağlamında gözlemcilere abone olup aboneliklerini iptal eder. ( Observable tarafından tanımlanır.) |
|
SubscribeOn<TResult>(Denetim) | Fazla Yüklendi. ( ControlObservable tarafından tanımlanır.) |
|
SubscribeOn<TResult>(Dispatcher) | Fazla Yüklendi. ( DispatcherObservable tarafından tanımlanır.) |
|
SubscribeOn<TResult>(DispatcherScheduler) | Fazla Yüklendi. ( DispatcherObservable tarafından tanımlanır.) |
|
SubscribeOn<TResult>(IScheduler) | Fazla Yüklendi. Belirtilen zamanlayıcıda zaman uyumsuz olarak gözlemcilere abone olup aboneliklerini iptal eder. ( Observable tarafından tanımlanır.) |
|
SubscribeOnDispatcher<TResult> | ( DispatcherObservable tarafından tanımlanır.) |
|
TResult>() eşitleme< | Fazla Yüklendi. Gözlemlenebilir diziyi eşitler. ( Observable tarafından tanımlanır.) |
|
Eşitleme<TResult>(Nesne) | Fazla Yüklendi. Gözlemlenebilir diziyi eşitler. ( Gözlemlenebilir tarafından tanımlanır.) |
|
TResult alma<> | Gözlemlenebilir bir sıranın başlangıcından belirtilen sayıda bitişik değer döndürür. ( Gözlemlenebilir tarafından tanımlanır.) |
|
TakeLast<TResult> | Gözlemlenebilir bir dizinin sonundan belirtilen sayıda bitişik öğe döndürür. ( Gözlemlenebilir tarafından tanımlanır.) |
|
TakeUntil<TResult, TOther> | Diğer gözlemlenebilir dizi bir değer üretinceye kadar kaynak gözlemlenebilir dizideki değerleri döndürür. ( Gözlemlenebilir tarafından tanımlanır.) |
|
TakeWhile<TResult>(Func<TResult, Boolean>) | Fazla Yüklendi. Belirtilen koşul true olduğu sürece gözlemlenebilir bir diziden değerler döndürür ve kalan değerleri atlar. ( Gözlemlenebilir tarafından tanımlanır.) |
|
TakeWhile<TResult>(Func<TResult, Int32, Boolean>) | Fazla Yüklendi. Belirtilen koşul true olduğu sürece gözlemlenebilir bir diziden değerler döndürür ve kalan değerleri atlar. ( Gözlemlenebilir tarafından tanımlanır.) |
|
Ardından<TResult, TResult> | Gözlemlenebilir dizi kullanılabilir bir değere sahip olduğunda ve değeri projelendirdiğinde eşleşir. ( Gözlemlenebilir tarafından tanımlanır.) |
|
TResult>(TimeSpan) kısıtlaması< | Fazla Yüklendi. Belirtilen kaynak ve dueTime ile süresi dolmadan önce başka bir değer tarafından takip edilen gözlemlenebilir bir dizideki değerleri yoksayar. ( Gözlemlenebilir tarafından tanımlanır.) |
|
TResult'u> Kısıtlama<(TimeSpan, IScheduler) | Fazla Yüklendi. Belirtilen kaynak, dueTime ve scheduler ile süresi dolmadan önce başka bir değer tarafından takip edilen gözlemlenebilir bir dizideki değerleri yoksayar. ( Gözlemlenebilir tarafından tanımlanır.) |
|
TimeInterval<TResult>() | Fazla Yüklendi. Belirtilen kaynakla gözlemlenebilir bir dizide ardışık değerler arasındaki zaman aralığını kaydeder. ( Gözlemlenebilir tarafından tanımlanır.) |
|
TimeInterval<TResult>(IScheduler) | Fazla Yüklendi. Belirtilen kaynak ve zamanlayıcı ile gözlemlenebilir bir dizide ardışık değerler arasındaki zaman aralığını kaydeder. ( Gözlemlenebilir tarafından tanımlanır.) |
|
Zaman Aşımı<TResult>(TimeSpan) | Fazla Yüklendi. DueTime geçtiğinde gözlemlenebilir diziyi veya TimeoutException'u döndürür. ( Gözlemlenebilir tarafından tanımlanır.) |
|
Zaman Aşımı<TResult>(DateTimeOffset) | Fazla Yüklendi. DueTime geçtiğinde gözlemlenebilir diziyi veya TimeoutException'u döndürür. ( Gözlemlenebilir tarafından tanımlanır.) |
|
Zaman Aşımı<TResult>(TimeSpan, IObservable<TResult>) | Fazla Yüklendi. DueTime geçtiğinde kaynak gözlemlenebilir diziyi veya diğer gözlemlenebilir diziyi döndürür. ( Gözlemlenebilir tarafından tanımlanır.) |
|
Zaman Aşımı<TResult>(DateTimeOffset, IObservable<TResult>) | Fazla Yüklendi. DueTime geçtiğinde gözlemlenebilir diziyi veya TimeoutException'u döndürür. ( Gözlemlenebilir tarafından tanımlanır.) |
|
Zaman Aşımı<TResult>(TimeSpan, IScheduler) | Fazla Yüklendi. DueTime geçtiğinde gözlemlenebilir diziyi veya TimeoutException'u döndürür. ( Gözlemlenebilir tarafından tanımlanır.) |
|
Zaman Aşımı<TResult>(DateTimeOffset, IScheduler) | Fazla Yüklendi. DueTime geçtiğinde gözlemlenebilir diziyi veya TimeoutException'u döndürür. ( Gözlemlenebilir tarafından tanımlanır.) |
|
Zaman Aşımı<TResult>(TimeSpan, IObservable<TResult>, IScheduler) | Fazla Yüklendi. DueTime geçtiğinde kaynak gözlemlenebilir diziyi veya diğer gözlemlenebilir diziyi döndürür. ( Gözlemlenebilir tarafından tanımlanır.) |
|
Zaman Aşımı<TResult>(DateTimeOffset, IObservable<TResult>, IScheduler) | Fazla Yüklendi. DueTime geçtiğinde kaynak gözlemlenebilir diziyi veya diğer gözlemlenebilir diziyi döndürür. ( Gözlemlenebilir tarafından tanımlanır.) |
|
Zaman damgası<TResult>() | Fazla Yüklendi. Belirtilen kaynakla gözlemlenebilir bir dizideki her değer için zaman damgasını kaydeder. ( Gözlemlenebilir tarafından tanımlanır.) |
|
Zaman damgası<TResult>(IScheduler) | Fazla Yüklendi. Belirtilen kaynak ve zamanlayıcı ile gözlemlenebilir bir dizideki her değer için zaman damgasını kaydeder. ( Gözlemlenebilir tarafından tanımlanır.) |
|
ToArray<TResult> | Gözlemlenebilir bir diziden dizi oluşturur. ( Gözlemlenebilir tarafından tanımlanır.) |
|
ToDictionary<TResult, TKey>(Func<TResult, TKey>) | Fazla Yüklendi. Belirtilen anahtar seçici işlevine göre gözlemlenebilir bir diziden sözlük oluşturur. ( Gözlemlenebilir tarafından tanımlanır.) |
|
ToDictionary<TResult, TKey>(Func<TResult, TKey>, IEqualityComparer<TKey>) | Fazla Yüklendi. Belirtilen anahtar seçici işlevine ve bir karşılaştırıcıya göre gözlemlenebilir bir diziden sözlük oluşturur. ( Gözlemlenebilir tarafından tanımlanır.) |
|
ToDictionary<TResult, TKey, TElement>(Func<TResult, TKey>, Func<TResult, TElement>) | Fazla Yüklendi. Belirtilen anahtar seçici işlevine ve öğe seçici işlevine göre gözlemlenebilir bir diziden sözlük oluşturur. ( Gözlemlenebilir tarafından tanımlanır.) |
|
ToDictionary<TResult, TKey, TElement>(Func<TResult, TKey>, Func<TResult, TElement>, IEqualityComparer<TKey>) | Fazla Yüklendi. Belirtilen anahtar seçici işlevine, karşılaştırıcıya ve öğe seçici işlevine göre gözlemlenebilir bir diziden sözlük oluşturur. ( Gözlemlenebilir tarafından tanımlanır.) |
|
ToEnumerable<TResult> | Gözlemlenebilir bir diziyi numaralandırılabilir bir diziye dönüştürür. ( Gözlemlenebilir tarafından tanımlanır.) |
|
ToEvent<TResult> | Gözlemlenebilir bir diziyi, belirtilen kaynağa sahip bir .NET olayına sahip bir nesne olarak kullanıma sunar. ( Gözlemlenebilir tarafından tanımlanır.) |
|
ToList<TResult> | Gözlemlenebilir bir diziden liste oluşturur. ( Gözlemlenebilir tarafından tanımlanır.) |
|
ToLookup<TResult, TKey>(Func<TResult, TKey>) | Fazla Yüklendi. Belirtilen anahtar seçici işlevine göre gözlemlenebilir bir diziden arama oluşturur. ( Gözlemlenebilir tarafından tanımlanır.) |
|
ToLookup<TResult, TKey>(Func<TResult, TKey>, IEqualityComparer<TKey>) | Fazla Yüklendi. Belirtilen anahtar seçici işlevine ve bir karşılaştırıcıya göre gözlemlenebilir bir diziden arama oluşturur. ( Gözlemlenebilir tarafından tanımlanır.) |
|
ToLookup<TResult, TKey, TElement>(Func<TResult, TKey>, Func<TResult, TElement>) | Fazla Yüklendi. Belirtilen anahtar seçici işlevine ve öğe seçici işlevine göre gözlemlenebilir bir diziden arama oluşturur. ( Gözlemlenebilir tarafından tanımlanır.) |
|
ToLookup<TResult, TKey, TElement>(Func<TResult, TKey>, Func<TResult, TElement>, IEqualityComparer<TKey>) | Fazla Yüklendi. Belirtilen anahtar seçici işlevine, karşılaştırıcıya ve öğe seçici işlevine göre gözlemlenebilir bir diziden arama oluşturur. ( Gözlemlenebilir tarafından tanımlanır.) |
|
ToNotifier<TSource> | Gözlemciden bir bildirim geri çağırması oluşturur. ( Gözlemci tarafından tanımlanır.) |
|
ToTask<TResult>() | Fazla Yüklendi. Gözlemlenebilir dizinin son değerini içeren bir görev döndürür. ( TaskObservableExtensions tarafından tanımlanır.) |
|
ToTask<TResult>(Nesne) | Fazla Yüklendi. Gözlemlenebilir dizinin son değerini içeren bir görev döndürür. ( TaskObservableExtensions tarafından tanımlanır.) |
|
ToTask<TResult>(CancellationToken) | Fazla Yüklendi. Gözlemlenebilir dizinin son değerini içeren bir görev döndürür. ( TaskObservableExtensions tarafından tanımlanır.) |
|
ToTask<TResult>(CancellationToken, Object) | Fazla Yüklendi. Gözlemlenebilir dizinin son değerini içeren bir görev döndürür. ( TaskObservableExtensions tarafından tanımlanır.) |
|
Where<TResult>(Func<TResult, Boolean>) | Fazla Yüklendi. Bir koşula göre gözlemlenebilir bir dizinin öğelerini filtreler. ( Gözlemlenebilir tarafından tanımlanır.) |
|
Where<TResult>(Func<TResult, Int32, Boolean>) | Fazla Yüklendi. Öğenin dizinini birleştirerek bir koşula göre gözlemlenebilir bir dizinin öğelerini filtreler. ( Gözlemlenebilir tarafından tanımlanır.) |
|
Pencere<TResult>(Int32) | Fazla Yüklendi. Gözlemlenebilir bir dizideki her öğeyi, öğe sayısı bilgilerine göre oluşturulan ardışık örtüşmeyen pencereler halinde projelendirir. ( Gözlemlenebilir tarafından tanımlanır.) |
|
Pencere<TResult>(TimeSpan) | Fazla Yüklendi. Gözlemlenebilir bir dizinin her bir öğesini zamanlama bilgilerine göre oluşturulan ardışık örtüşmeyen pencerelere projeler. ( Gözlemlenebilir tarafından tanımlanır.) |
|
Pencere<TResult>(Int32, Int32) | Fazla Yüklendi. Gözlemlenebilir bir dizinin her öğesini, öğe sayısı bilgilerine göre oluşturulan sıfır veya daha fazla pencereye projeler. ( Gözlemlenebilir tarafından tanımlanır.) |
|
Pencere<TResult>(TimeSpan, IScheduler) | Fazla Yüklendi. Gözlemlenebilir bir dizinin her bir öğesini zamanlama bilgilerine göre oluşturulan ardışık örtüşmeyen pencerelere projeler. ( Gözlemlenebilir tarafından tanımlanır.) |
|
Pencere<TResult>(TimeSpan, TimeSpan) | Fazla Yüklendi. Gözlemlenebilir bir dizideki her öğeyi zamanlama bilgilerine göre oluşturulan sıfır veya daha fazla pencereye projeler. ( Gözlemlenebilir tarafından tanımlanır.) |
|
Pencere<TResult>(TimeSpan, Int32) | Fazla Yüklendi. Gözlemlenebilir bir dizinin her öğesini, dolu olduğunda veya belirli bir süre geçtiğinde tamamlanan bir pencereye projeler. ( Gözlemlenebilir tarafından tanımlanır.) |
|
Pencere<TResult>(TimeSpan, TimeSpan, IScheduler) | Fazla Yüklendi. Gözlemlenebilir bir dizideki her öğeyi zamanlama bilgilerine göre oluşturulan sıfır veya daha fazla pencereye projeler. ( Gözlemlenebilir tarafından tanımlanır.) |
|
Pencere<TResult>(TimeSpan, Int32, IScheduler) | Fazla Yüklendi. Gözlemlenebilir bir dizinin her öğesini, dolu olduğunda veya belirli bir süre geçtiğinde tamamlanan bir pencereye projeler. ( Gözlemlenebilir tarafından tanımlanır.) |
|
Pencere<TResult, TWindowClosing>(Func<IObservable<TWindowClosing>>) | Fazla Yüklendi. Gözlemlenebilir bir dizinin her öğesini ardışık örtüşmeyen pencerelere projeler. ( Gözlemlenebilir tarafından tanımlanır.) |
|
Pencere<TResult, TWindowOpening, TWindowClosing>(IObservable<TWindowOpening>, Func<TWindowOpening, IObservable<TWindowClosing>>) | Fazla Yüklendi. Gözlemlenebilir bir dizinin her öğesini sıfır veya daha fazla pencereye projeler. ( Gözlemlenebilir tarafından tanımlanır.) |
|
Zip<TResult, TSecond, TResult>(IObservable<TSecond>, Func<TResult, TSecond, TResult>) | Fazla Yüklendi. İki gözlemlenebilir diziyi, öğelerini çift yönlü bir şekilde birleştirerek tek bir gözlemlenebilir dizide birleştirir. ( Gözlemlenebilir tarafından tanımlanır.) |
|
Zip<TResult, TSecond, TResult>(IEnumerable<TSecond>, Func<TResult, TSecond, TResult>) | Fazla Yüklendi. Seçici işlevini kullanarak gözlemlenebilir bir diziyi ve numaralandırılabilir bir diziyi gözlemlenebilir tek bir dizide birleştirir. ( Gözlemlenebilir tarafından tanımlanır.) |
Üst
Açıklamalar
Bu konu arabirimi, başka bir türün gözlemlenebilir dizisini yayımlarken bir konuda bir türün gözlemlenebilir dizisini gözlemleme esnekliği sağlar.
Örnekler
Bu örnekte, bir ISubject<TSource, TResult> uygulayarak bir türün gözlemlenebilir sırasını gözlemlerken başka bir türde gözlemlenebilir bir dizi yayımlanırken gösterilmektedir. Bu örnekteki AsciiConverterSubject, char türünde dizileri gözlemleyerek ve gözlemlenebilir bir int dizisi yayımlayarak uygulamayı gösterir. Yayımlanan gözlemlenebilir int dizisi, gözlemlediği her karakter değeri için ASCII kodudur.
using System;
using System.Collections.Generic;
using System.Reactive.Linq;
using System.Reactive.Subjects;
using System.Reactive.Concurrency;
using System.Reactive.Disposables;
using System.Threading;
namespace Example
{
class Program
{
static void Main()
{
//****************************************************************************************//
//*** Create an observable sequence of char from console input until enter is pressed. ***//
//****************************************************************************************//
IObservable<char> keySequence = Observable.Create<char>(observer =>
{
bool bContinue = true;
while (bContinue)
{
ConsoleKeyInfo keyInfo = Console.ReadKey(true);
if (keyInfo.Key != ConsoleKey.Enter)
{
observer.OnNext(keyInfo.KeyChar);
}
else
{
observer.OnCompleted();
bContinue = false;
}
}
return (() => { });
});
//****************************************************************************************//
//*** Create an AsciiConverterSubject which takes a source type of char and returns an ***//
//*** observable sequence of int which is the ASCII code for source items of char. ***//
//****************************************************************************************//
AsciiConverterSubject myConverterSubject = new AsciiConverterSubject();
//****************************************************************************************//
//*** Subscribe to the keySequence on the .NET threadpool so the main thread can ***//
//*** create subscriptions to the AsciiConverterSubject ***//
//****************************************************************************************//
IDisposable subscription = keySequence.SubscribeOn(Scheduler.ThreadPool).Subscribe(myConverterSubject);
Console.WriteLine("\nEnter a sequence of keys to have the AsciiConverterSubject\nconvert the keys to their ASCII code values.\n");
Console.WriteLine("Press ENTER to terminate the observable sequence...\n");
//****************************************************************************************//
//*** Subscribe to the AsciiConverterSubject and write the ASCII code values to the ***//
//*** console window. ***//
//*** ***//
//*** The main thread will wait on the completion of the keySequence. It completes ***//
//*** when ENTER is pressed. ***//
//****************************************************************************************//
EventWaitHandle waitHandle = new EventWaitHandle(false, EventResetMode.ManualReset);
myConverterSubject.Subscribe(c => Console.WriteLine("Ascii Char code {0} entered.",c), () => waitHandle.Set());
waitHandle.WaitOne();
//***************************************//
//*** Explicitly releasing resources. ***//
//***************************************//
subscription.Dispose();
myConverterSubject.Dispose();
}
}
//***********************************************************************************************//
//*** ***//
//*** The AsciiConverterSubject demonstrates an implementation of ISubject<TSource, TResult>. ***//
//*** It is used to subscribe to an observable sequence of char. It publishes an observable ***//
//*** sequence of int which should be the ASCII code for each char value it observes. ***//
//*** ***//
//***********************************************************************************************//
class AsciiConverterSubject : ISubject<char, int>, IDisposable
{
private List<IObserver<int>> observerList;
private bool isDisposed;
private bool isStopped;
object gate = new object();
Exception exception;
public AsciiConverterSubject()
{
observerList = new List<IObserver<int>>();
}
public void OnCompleted()
{
//****************************************************************************************//
//*** Make sure the OnCompleted operation is not preempted by another operation ***//
//*** which would break the expected behavior. For example, don't allow an error from ***//
//*** OnError preempt OnCompleted from anotther thread. Then OnCompleted would follow ***//
//*** an error. That would be an incorrect behavior. ***//
//****************************************************************************************//
lock (gate)
{
CheckDisposed();
if (!isStopped)
{
foreach (IObserver<int> observer in observerList)
{
observer.OnCompleted();
}
observerList.Clear();
isStopped = true;
}
}
}
public void OnError(Exception error)
{
if (error == null)
throw new ArgumentException("Exception error should not be null.");
//****************************************************************************************//
//*** Make sure the OnError operation is not preempted by another operation which ***//
//*** would break the expected behavior. For example, don't allow unsubscribe or an ***//
//*** OnCompleted operation to preempt OnError from another thread. This would result ***//
//*** in an error following completion. That would be an incorrect behavior. ***//
//****************************************************************************************//
lock (gate)
{
CheckDisposed();
if (!isStopped)
{
exception = error;
foreach (IObserver<int> observer in observerList)
{
observer.OnError(error);
}
observerList.Clear();
isStopped = true;
}
}
}
public void OnNext(char value)
{
//****************************************************************************************//
//*** Make sure the OnNext operation is not preempted by another operation which ***//
//*** would break the expected behavior. For example, don't allow unsubscribe, errors ***//
//*** or an OnCompleted operation to preempt OnNext from another thread. This would ***//
//*** have the result of items in a sequence following completion, errors, or ***//
//*** unsubscribe. That would be an incorrect behavior. ***//
//****************************************************************************************//
lock (gate)
{
CheckDisposed();
if (!isStopped)
{
foreach (IObserver<int> observer in observerList)
{
observer.OnNext(Convert.ToInt32(value));
}
}
}
}
public IDisposable Subscribe(IObserver<int> observer)
{
if (observer == null)
throw new ArgumentException("observer should not BehaviorSubject null.");
//****************************************************************************************//
//*** Make sure Subscribe occurs in sync with the other operations so we keep the ***//
//*** correct behavior depending on whether an error has occurred or the observable ***//
//*** sequence has completed. ***//
//****************************************************************************************//
lock (gate)
{
CheckDisposed();
if (!isStopped)
{
observerList.Add(observer);
return new Subscription(observer, this);
}
else if (exception != null)
{
observer.OnError(exception);
return Disposable.Empty;
}
else
{
observer.OnCompleted();
return Disposable.Empty;
}
}
}
private void Unsubscribe(IObserver<int> observer)
{
//****************************************************************************************//
//*** Make sure Unsubscribe occurs in sync with the other operations so we keep the ***//
//*** correct behavior. ***//
//****************************************************************************************//
lock (gate)
{
observerList.Remove(observer);
}
}
public void Dispose()
{
//****************************************************************************************//
//*** Make sure Dispose occurs in sync with the other operations so we keep the ***//
//*** correct behavior. For example, Dispose shouldn't preempt the other operations ***//
//*** changing state variables after they have been checked. ***//
//****************************************************************************************//
lock (gate)
{
observerList.Clear();
isStopped = true;
isDisposed = true;
}
}
private void CheckDisposed()
{
if (isDisposed)
throw new ObjectDisposedException("Subject has been disposed.");
}
//************************************************************************************//
//*** ***//
//*** The Subscription class wraps each observer that creates a subscription. This ***//
//*** is needed to expose an IDisposable interface through which a observer can ***//
//*** cancel the subscription. ***//
//*** ***//
//************************************************************************************//
class Subscription : IDisposable
{
private AsciiConverterSubject subject;
private IObserver<int> observer;
public Subscription(IObserver<int> obs, AsciiConverterSubject sub)
{
subject = sub;
observer = obs;
}
public void Dispose()
{
subject.Unsubscribe(observer);
}
}
}
}
Aşağıdaki çıkış örnek kod tarafından oluşturulmuştur.
Enter a sequence of keys to have the AsciiConverterSubject
convert the keys to their ASCII code values.
Press ENTER to terminate the observable sequence...
Ascii Char code 59 entered.
Ascii Char code 108 entered.
Ascii Char code 115 entered.
Ascii Char code 100 entered.
Ascii Char code 107 entered.
Ascii Char code 102 entered.
Ascii Char code 59 entered.
Ascii Char code 108 entered.
Ascii Char code 115 entered.
Ascii Char code 100 entered.
Ascii Char code 107 entered.
Ascii Char code 102 entered.
Ascii Char code 59 entered.
Ascii Char code 108 entered.
Ascii Char code 115 entered.
Ascii Char code 107 entered.
Ascii Char code 100 entered.
Ascii Char code 59 entered.
Ascii Char code 102 entered.
Ascii Char code 108 entered.
Ascii Char code 115 entered.
Ascii Char code 107 entered.
Ascii Char code 100 entered.