What are the default Schedulers for each observable operator?

by

Wow, that was not trivial to find…

Deep within the bowels of the System.Reactive.Concurrency namespace, there is an internal static class called SchedulerDefaults, which is declared as:

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 is used by:

Start, ToAsync, FromAsyncPattern

ConstantTimeOperations is used by:

Empty, GetSchedulerForCurrentContext, Return, StartWith, Throw

Iteration is used by:

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

TailRecursion is used by:

Run

TimeBasedOperations is used by:

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

More Related Contents:

  1. ObserveOn and SubscribeOn – where the work is being done
  2. How to throttle event stream using RX?
  3. How can I implement an exhaustMap handler in Rx.Net?
  4. Why are Subjects not recommended in .NET Reactive Extensions?
  5. How can I see what my reactive extensions query is doing?
  6. Write an Rx “RetryAfter” extension method
  7. Good introduction to the .NET Reactive Framework [closed]
  8. With Rx, how do I ignore all-except-the-latest value when my Subscribe method is running
  9. Does reactive extensions support rolling buffers?
  10. Rx: How can I respond immediately, and throttle subsequent requests
  11. A way to push buffered events in even intervals
  12. How can I alternately buffer and flow a live data stream in Rx
  13. What’s a good way to run periodic tasks using Rx, with a single concurrent execution restriction?
  14. How to call back async function from Rx Subscribe?
  15. Reactive Extensions for .NET (Rx): Take action once all events are completed
  16. Pause and Resume Subscription on cold IObservable
  17. what are the methods “public override bool equals(object obj)” and “public override int gethashcode()” doing? [closed]
  18. Get string between two strings in a string
  19. Check whether an array is a subset of another
  20. Json.net serialize/deserialize derived types?
  21. Why doesn’t .NET/C# optimize for tail-call recursion?
  22. Stop TabControl from recreating its children
  23. Can I “multiply” a string (in C#)?
  24. How to execute task in the wpf background while able to provide report and allow cancellation?
  25. What are some reasons NetworkStream.Read would hang/block?
  26. System.IO.File.Create locking a file
  27. Getting System.Net.Mail.MailMessage as a MemoryStream in .NET 4.5 beta
  28. open file in exclusive mode in C#
  29. Why can’t we define a variable inside a while loop?
  30. C# – Get mac address in Universal Apps

Leave a Comment