प्रत्येक पर्यवेक्षक ऑपरेटर के लिए डिफ़ॉल्ट शेड्यूलर क्या हैं?

Question

This page on MSDN कहा गया है कि

आप अधिभार जो एक तर्क के रूप में एक अनुसूचक लेता है का उपयोग नहीं करते हैं, तो आरएक्स एक डिफ़ॉल्ट अनुसूचक कम से कम संगामिति के सिद्धांत का उपयोग करके ले जाएगा। इसका अर्थ यह है कि शेड्यूलर जो कम से कम समेकन को प्रस्तुत करता है जो ऑपरेटर की आवश्यकताओं को पूरा करता है। उदाहरण के लिए, ऑपरेटर एक सीमित और छोटी संख्या में संदेशों के साथ एक अवलोकन योग्य लौटने के लिए, आरएक्स तत्काल कॉल करता है। संभावित संभावित या असीमित संदेशों को वापस करने वाले ऑपरेटरों के लिए, CurrentThread को कॉल किया जाता है। टाइमर का उपयोग करने वाले ऑपरेटरों के लिए, थ्रेडपूल का उपयोग किया जाता है।

मैं वास्तव में एक संदर्भ पत्र चाहता हूं जिसके लिए अवलोकन करने वाले ऑपरेटरों का उपयोग डिफ़ॉल्ट डिफ़ॉल्ट शेड्यूलर का उपयोग करता है, लेकिन मुझे कहीं भी नहीं मिल रहा है। प्रत्येक पर्यवेक्षक ऑपरेटर के लिए डिफ़ॉल्ट शेड्यूलर क्या हैं?

Answer 1

वाह, यह पता लगाने के लिए तुच्छ नहीं था ...

System.Reactive.Concurrency नाम स्थान का आंत के भीतर गहरे, वहाँ एक आंतरिक स्थैतिक कक्षा, जो के रूप में घोषित किया जाता है SchedulerDefaults कहा जाता है:

internal static class SchedulerDefaults 
{ 
    internal static IScheduler AsyncConversions 
    { get { return DefaultScheduler.Instance; }} 

    internal static IScheduler ConstantTimeOperations 
    { get { return ImmediateScheduler.Instance; }} 

    internal static IScheduler Iteration 
    { get { return CurrentThreadScheduler.Instance; }} 

    internal static IScheduler TailRecursion 
    { get { return ImmediateScheduler.Instance; }} 

    internal static IScheduler TimeBasedOperations 
    { get { return DefaultScheduler.Instance; }} 
} 

AsyncConversions द्वारा किया जाता है:

Start, ToAsync, FromAsyncPattern 

ConstantTimeOperations द्वारा किया जाता है:

Empty, GetSchedulerForCurrentContext, Return, StartWith, Throw 

Iteration द्वारा किया जाता है:

Generate, Range, Repeat, TakeLast, ToObservable, and the ReplaySubject<T> 

TailRecursion द्वारा किया जाता है:

Run 

TimeBasedOperations द्वारा किया जाता है:

Buffer, Delay, DelaySubscription, Generate, Interval, Sample, Skip, SkipLast 
SkipUntil, Take, TakeLast, TakeLastBuffer, TakeUntil, Throttle, TimeInterval, 
Timeout, Timer, Timestamp, Window