[assembly: System.CLSCompliant(true)] [assembly: System.Resources.NeutralResourcesLanguage("en-US")] [assembly: System.Runtime.CompilerServices.InternalsVisibleTo(@"Tests.System.Reactive, PublicKey=00240000048000009400000006020000002400005253413100040000010001008f5cff058631087031f8350f30a36fa078027e5df2316b564352dc9eb7af7ce856016d3c5e9d058036fe73bb5c83987bd3fc0793fbe25d633cc4f37c2bd5f1d717cd2a81661bec08f0971dc6078e17bde372b89005e7738a0ebd501b896ca3e8315270ff64df7809dd912c372df61785a5085b3553b7872e39b1b1cc0ff5a6bc")] [assembly: System.Runtime.CompilerServices.InternalsVisibleTo(@"Tests.System.Reactive.Uwp.DeviceRunner, PublicKey=00240000048000009400000006020000002400005253413100040000010001008f5cff058631087031f8350f30a36fa078027e5df2316b564352dc9eb7af7ce856016d3c5e9d058036fe73bb5c83987bd3fc0793fbe25d633cc4f37c2bd5f1d717cd2a81661bec08f0971dc6078e17bde372b89005e7738a0ebd501b896ca3e8315270ff64df7809dd912c372df61785a5085b3553b7872e39b1b1cc0ff5a6bc")] [assembly: System.Runtime.InteropServices.ComVisible(false)] [assembly: System.Runtime.Versioning.TargetFramework(".NETFramework,Version=v4.7.2", FrameworkDisplayName=".NET Framework 4.7.2")] namespace System { public static class ObservableExtensions { public static System.IDisposable Subscribe(this System.IObservable source) { } public static System.IDisposable Subscribe(this System.IObservable source, System.Action onNext) { } public static void Subscribe(this System.IObservable source, System.Threading.CancellationToken token) { } public static System.IDisposable Subscribe(this System.IObservable source, System.Action onNext, System.Action onCompleted) { } public static System.IDisposable Subscribe(this System.IObservable source, System.Action onNext, System.Action onError) { } public static void Subscribe(this System.IObservable source, System.Action onNext, System.Threading.CancellationToken token) { } public static void Subscribe(this System.IObservable source, System.IObserver observer, System.Threading.CancellationToken token) { } public static void Subscribe(this System.IObservable source, System.Action onNext, System.Action onCompleted, System.Threading.CancellationToken token) { } public static System.IDisposable Subscribe(this System.IObservable source, System.Action onNext, System.Action onError, System.Action onCompleted) { } public static void Subscribe(this System.IObservable source, System.Action onNext, System.Action onError, System.Threading.CancellationToken token) { } public static void Subscribe(this System.IObservable source, System.Action onNext, System.Action onError, System.Action onCompleted, System.Threading.CancellationToken token) { } public static System.IDisposable SubscribeSafe(this System.IObservable source, System.IObserver observer) { } } } namespace System.Reactive { public sealed class AnonymousObservable : System.Reactive.ObservableBase { public AnonymousObservable(System.Func, System.IDisposable> subscribe) { } protected override System.IDisposable SubscribeCore(System.IObserver observer) { } } public sealed class AnonymousObserver : System.Reactive.ObserverBase { public AnonymousObserver(System.Action onNext) { } public AnonymousObserver(System.Action onNext, System.Action onCompleted) { } public AnonymousObserver(System.Action onNext, System.Action onError) { } public AnonymousObserver(System.Action onNext, System.Action onError, System.Action onCompleted) { } protected override void OnCompletedCore() { } protected override void OnErrorCore(System.Exception error) { } protected override void OnNextCore(T value) { } } public abstract class EventPatternSourceBase { protected EventPatternSourceBase(System.IObservable> source, System.Action, System.Reactive.EventPattern> invokeHandler) { } protected void Add(System.Delegate handler, System.Action invoke) { } protected void Remove(System.Delegate handler) { } } public class EventPattern : System.Reactive.EventPattern { public EventPattern(object? sender, TEventArgs e) { } } public class EventPattern : System.IEquatable>, System.Reactive.IEventPattern { public EventPattern(TSender? sender, TEventArgs e) { } public TEventArgs EventArgs { get; } public TSender Sender { get; } public void Deconstruct(out TSender? sender, out TEventArgs e) { } public bool Equals(System.Reactive.EventPattern? other) { } public override bool Equals(object? obj) { } public override int GetHashCode() { } public static bool operator !=(System.Reactive.EventPattern first, System.Reactive.EventPattern second) { } public static bool operator ==(System.Reactive.EventPattern first, System.Reactive.EventPattern second) { } } [System.AttributeUsage(System.AttributeTargets.All)] [System.Reactive.Experimental] public sealed class ExperimentalAttribute : System.Attribute { public ExperimentalAttribute() { } } public interface IEventPatternSource { event System.EventHandler OnNext; } public interface IEventPattern { TEventArgs EventArgs { get; } TSender Sender { get; } } public interface IEventSource { event System.Action OnNext; } public interface IObserver { TResult OnCompleted(); TResult OnError(System.Exception exception); TResult OnNext(TValue value); } public interface ITaskObservableAwaiter : System.Runtime.CompilerServices.INotifyCompletion { bool IsCompleted { get; } T GetResult(); } [System.Runtime.CompilerServices.AsyncMethodBuilder(typeof(System.Runtime.CompilerServices.TaskObservableMethodBuilder))] public interface ITaskObservable : System.IObservable { System.Reactive.ITaskObservableAwaiter GetAwaiter(); } [System.Reactive.Experimental] public class ListObservable : System.Collections.Generic.ICollection, System.Collections.Generic.IEnumerable, System.Collections.Generic.IList, System.Collections.IEnumerable, System.IObservable { public ListObservable(System.IObservable source) { } public int Count { get; } public bool IsReadOnly { get; } public T this[int index] { get; set; } public T Value { get; } public void Add(T item) { } public void Clear() { } public bool Contains(T item) { } public void CopyTo(T[] array, int arrayIndex) { } public System.Collections.Generic.IEnumerator GetEnumerator() { } public int IndexOf(T item) { } public void Insert(int index, T item) { } public bool Remove(T item) { } public void RemoveAt(int index) { } public System.IDisposable Subscribe(System.IObserver observer) { } } public static class Notification { public static System.Reactive.Notification CreateOnCompleted() { } public static System.Reactive.Notification CreateOnError(System.Exception error) { } public static System.Reactive.Notification CreateOnNext(T value) { } } public enum NotificationKind { OnNext = 0, OnError = 1, OnCompleted = 2, } [System.Serializable] public abstract class Notification : System.IEquatable> { protected Notification() { } public abstract System.Exception? Exception { get; } public abstract bool HasValue { get; } public abstract System.Reactive.NotificationKind Kind { get; } public abstract T Value { get; } public abstract void Accept(System.IObserver observer); public abstract void Accept(System.Action onNext, System.Action onError, System.Action onCompleted); public abstract TResult Accept(System.Reactive.IObserver observer); public abstract TResult Accept(System.Func onNext, System.Func onError, System.Func onCompleted); public abstract bool Equals(System.Reactive.Notification? other); public override bool Equals(object? obj) { } public System.IObservable ToObservable() { } public System.IObservable ToObservable(System.Reactive.Concurrency.IScheduler scheduler) { } public static bool operator !=(System.Reactive.Notification left, System.Reactive.Notification right) { } public static bool operator ==(System.Reactive.Notification left, System.Reactive.Notification right) { } } public abstract class ObservableBase : System.IObservable { protected ObservableBase() { } public System.IDisposable Subscribe(System.IObserver observer) { } protected abstract System.IDisposable SubscribeCore(System.IObserver observer); } public static class Observer { public static System.IObserver AsObserver(this System.IObserver observer) { } public static System.IObserver Checked(this System.IObserver observer) { } public static System.IObserver Create(System.Action onNext) { } public static System.IObserver Create(System.Action onNext, System.Action onCompleted) { } public static System.IObserver Create(System.Action onNext, System.Action onError) { } public static System.IObserver Create(System.Action onNext, System.Action onError, System.Action onCompleted) { } public static System.IObserver NotifyOn(this System.IObserver observer, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.IObserver NotifyOn(this System.IObserver observer, System.Threading.SynchronizationContext context) { } public static System.IObserver Synchronize(System.IObserver observer) { } public static System.IObserver Synchronize(System.IObserver observer, bool preventReentrancy) { } public static System.IObserver Synchronize(System.IObserver observer, object gate) { } public static System.IObserver Synchronize(System.IObserver observer, System.Reactive.Concurrency.AsyncLock asyncLock) { } public static System.Action> ToNotifier(this System.IObserver observer) { } public static System.IObserver ToObserver(this System.Action> handler) { } public static System.IObserver ToObserver(this System.IProgress progress) { } public static System.IProgress ToProgress(this System.IObserver observer) { } public static System.IProgress ToProgress(this System.IObserver observer, System.Reactive.Concurrency.IScheduler scheduler) { } } public abstract class ObserverBase : System.IDisposable, System.IObserver { protected ObserverBase() { } public void Dispose() { } protected virtual void Dispose(bool disposing) { } public void OnCompleted() { } protected abstract void OnCompletedCore(); public void OnError(System.Exception error) { } protected abstract void OnErrorCore(System.Exception error); public void OnNext(T value) { } protected abstract void OnNextCore(T value); } [System.Serializable] public readonly struct TimeInterval : System.IEquatable> { public TimeInterval(T value, System.TimeSpan interval) { } public System.TimeSpan Interval { get; } public T Value { get; } public void Deconstruct(out T value, out System.TimeSpan interval) { } public bool Equals(System.Reactive.TimeInterval other) { } public override bool Equals(object? obj) { } public override int GetHashCode() { } public override string ToString() { } public static bool operator !=(System.Reactive.TimeInterval first, System.Reactive.TimeInterval second) { } public static bool operator ==(System.Reactive.TimeInterval first, System.Reactive.TimeInterval second) { } } public static class Timestamped { public static System.Reactive.Timestamped Create(T value, System.DateTimeOffset timestamp) { } } [System.Serializable] public readonly struct Timestamped : System.IEquatable> { public Timestamped(T value, System.DateTimeOffset timestamp) { } public System.DateTimeOffset Timestamp { get; } public T Value { get; } public void Deconstruct(out T value, out System.DateTimeOffset timestamp) { } public bool Equals(System.Reactive.Timestamped other) { } public override bool Equals(object? obj) { } public override int GetHashCode() { } public override string ToString() { } public static bool operator !=(System.Reactive.Timestamped first, System.Reactive.Timestamped second) { } public static bool operator ==(System.Reactive.Timestamped first, System.Reactive.Timestamped second) { } } [System.Serializable] public readonly struct Unit : System.IEquatable { public static System.Reactive.Unit Default { get; } public bool Equals(System.Reactive.Unit other) { } public override bool Equals(object? obj) { } public override int GetHashCode() { } public override string ToString() { } public static bool operator !=(System.Reactive.Unit first, System.Reactive.Unit second) { } public static bool operator ==(System.Reactive.Unit first, System.Reactive.Unit second) { } } } namespace System.Reactive.Concurrency { public sealed class AsyncLock : System.IDisposable { public AsyncLock() { } public void Dispose() { } public void Wait(System.Action action) { } } public class ControlScheduler : System.Reactive.Concurrency.LocalScheduler, System.Reactive.Concurrency.ISchedulerPeriodic { public ControlScheduler(System.Windows.Forms.Control control) { } public System.Windows.Forms.Control Control { get; } public override System.IDisposable Schedule(TState state, System.Func action) { } public override System.IDisposable Schedule(TState state, System.TimeSpan dueTime, System.Func action) { } public System.IDisposable SchedulePeriodic(TState state, System.TimeSpan period, System.Func action) { } } public sealed class CurrentThreadScheduler : System.Reactive.Concurrency.LocalScheduler { [System.Obsolete("This instance property is no longer supported. Use CurrentThreadScheduler.IsSched" + "uleRequired instead.")] public bool ScheduleRequired { get; } public static System.Reactive.Concurrency.CurrentThreadScheduler Instance { get; } public static bool IsScheduleRequired { get; } public override System.IDisposable Schedule(TState state, System.TimeSpan dueTime, System.Func action) { } } public sealed class DefaultScheduler : System.Reactive.Concurrency.LocalScheduler, System.Reactive.Concurrency.ISchedulerPeriodic { public static System.Reactive.Concurrency.DefaultScheduler Instance { get; } protected override object? GetService(System.Type serviceType) { } public override System.IDisposable Schedule(TState state, System.Func action) { } public override System.IDisposable Schedule(TState state, System.TimeSpan dueTime, System.Func action) { } public System.IDisposable SchedulePeriodic(TState state, System.TimeSpan period, System.Func action) { } } public class DispatcherScheduler : System.Reactive.Concurrency.LocalScheduler, System.Reactive.Concurrency.ISchedulerPeriodic { public DispatcherScheduler(System.Windows.Threading.Dispatcher dispatcher) { } public DispatcherScheduler(System.Windows.Threading.Dispatcher dispatcher, System.Windows.Threading.DispatcherPriority priority) { } public System.Windows.Threading.Dispatcher Dispatcher { get; } public System.Windows.Threading.DispatcherPriority Priority { get; } public static System.Reactive.Concurrency.DispatcherScheduler Current { get; } [System.Obsolete("Use the Current property to retrieve the DispatcherScheduler instance for the cur" + "rent thread\'s Dispatcher object.")] public static System.Reactive.Concurrency.DispatcherScheduler Instance { get; } public override System.IDisposable Schedule(TState state, System.Func action) { } public override System.IDisposable Schedule(TState state, System.TimeSpan dueTime, System.Func action) { } public System.IDisposable SchedulePeriodic(TState state, System.TimeSpan period, System.Func action) { } } public sealed class EventLoopScheduler : System.Reactive.Concurrency.LocalScheduler, System.IDisposable, System.Reactive.Concurrency.ISchedulerPeriodic { public EventLoopScheduler() { } public EventLoopScheduler(System.Func threadFactory) { } public void Dispose() { } public override System.IDisposable Schedule(TState state, System.TimeSpan dueTime, System.Func action) { } public System.IDisposable SchedulePeriodic(TState state, System.TimeSpan period, System.Func action) { } public override System.Reactive.Concurrency.IStopwatch StartStopwatch() { } } [System.Diagnostics.DebuggerDisplay("\\{ Clock = {Clock} Now = {Now.ToString(\"O\")} \\}")] public class HistoricalScheduler : System.Reactive.Concurrency.HistoricalSchedulerBase { public HistoricalScheduler() { } public HistoricalScheduler(System.DateTimeOffset initialClock) { } public HistoricalScheduler(System.DateTimeOffset initialClock, System.Collections.Generic.IComparer comparer) { } protected override System.Reactive.Concurrency.IScheduledItem? GetNext() { } public override System.IDisposable ScheduleAbsolute(TState state, System.DateTimeOffset dueTime, System.Func action) { } } public abstract class HistoricalSchedulerBase : System.Reactive.Concurrency.VirtualTimeSchedulerBase { protected HistoricalSchedulerBase() { } protected HistoricalSchedulerBase(System.DateTimeOffset initialClock) { } protected HistoricalSchedulerBase(System.DateTimeOffset initialClock, System.Collections.Generic.IComparer comparer) { } protected override System.DateTimeOffset Add(System.DateTimeOffset absolute, System.TimeSpan relative) { } protected override System.DateTimeOffset ToDateTimeOffset(System.DateTimeOffset absolute) { } protected override System.TimeSpan ToRelative(System.TimeSpan timeSpan) { } } public interface IConcurrencyAbstractionLayer { bool SupportsLongRunning { get; } System.IDisposable QueueUserWorkItem(System.Action action, object? state); void Sleep(System.TimeSpan timeout); System.IDisposable StartPeriodicTimer(System.Action action, System.TimeSpan period); System.Reactive.Concurrency.IStopwatch StartStopwatch(); void StartThread(System.Action action, object? state); System.IDisposable StartTimer(System.Action action, object? state, System.TimeSpan dueTime); } public interface IScheduledItem { TAbsolute DueTime { get; } void Invoke(); } public interface IScheduler { System.DateTimeOffset Now { get; } System.IDisposable Schedule(TState state, System.Func action); System.IDisposable Schedule(TState state, System.DateTimeOffset dueTime, System.Func action); System.IDisposable Schedule(TState state, System.TimeSpan dueTime, System.Func action); } public interface ISchedulerLongRunning { System.IDisposable ScheduleLongRunning(TState state, System.Action action); } public interface ISchedulerPeriodic { System.IDisposable SchedulePeriodic(TState state, System.TimeSpan period, System.Func action); } public interface IStopwatch { System.TimeSpan Elapsed { get; } } public interface IStopwatchProvider { System.Reactive.Concurrency.IStopwatch StartStopwatch(); } public sealed class ImmediateScheduler : System.Reactive.Concurrency.LocalScheduler { public static System.Reactive.Concurrency.ImmediateScheduler Instance { get; } public override System.IDisposable Schedule(TState state, System.Func action) { } public override System.IDisposable Schedule(TState state, System.TimeSpan dueTime, System.Func action) { } } public abstract class LocalScheduler : System.IServiceProvider, System.Reactive.Concurrency.IScheduler, System.Reactive.Concurrency.IStopwatchProvider { protected LocalScheduler() { } public virtual System.DateTimeOffset Now { get; } protected virtual object? GetService(System.Type serviceType) { } public virtual System.IDisposable Schedule(TState state, System.Func action) { } public virtual System.IDisposable Schedule(TState state, System.DateTimeOffset dueTime, System.Func action) { } public abstract System.IDisposable Schedule(TState state, System.TimeSpan dueTime, System.Func action); public virtual System.Reactive.Concurrency.IStopwatch StartStopwatch() { } } public sealed class NewThreadScheduler : System.Reactive.Concurrency.LocalScheduler, System.Reactive.Concurrency.ISchedulerLongRunning, System.Reactive.Concurrency.ISchedulerPeriodic { public NewThreadScheduler() { } public NewThreadScheduler(System.Func threadFactory) { } public static System.Reactive.Concurrency.NewThreadScheduler Default { get; } public override System.IDisposable Schedule(TState state, System.TimeSpan dueTime, System.Func action) { } public System.IDisposable ScheduleLongRunning(TState state, System.Action action) { } public System.IDisposable SchedulePeriodic(TState state, System.TimeSpan period, System.Func action) { } public override System.Reactive.Concurrency.IStopwatch StartStopwatch() { } } public abstract class ScheduledItem : System.IComparable>, System.IDisposable, System.Reactive.Concurrency.IScheduledItem where TAbsolute : System.IComparable { protected ScheduledItem(TAbsolute dueTime, System.Collections.Generic.IComparer comparer) { } public TAbsolute DueTime { get; } public bool IsCanceled { get; } public void Cancel() { } public int CompareTo(System.Reactive.Concurrency.ScheduledItem? other) { } public override bool Equals(object? obj) { } public override int GetHashCode() { } public void Invoke() { } protected abstract System.IDisposable InvokeCore(); public static bool operator !=(System.Reactive.Concurrency.ScheduledItem? left, System.Reactive.Concurrency.ScheduledItem? right) { } public static bool operator <(System.Reactive.Concurrency.ScheduledItem left, System.Reactive.Concurrency.ScheduledItem right) { } public static bool operator <=(System.Reactive.Concurrency.ScheduledItem left, System.Reactive.Concurrency.ScheduledItem right) { } public static bool operator ==(System.Reactive.Concurrency.ScheduledItem? left, System.Reactive.Concurrency.ScheduledItem? right) { } public static bool operator >(System.Reactive.Concurrency.ScheduledItem left, System.Reactive.Concurrency.ScheduledItem right) { } public static bool operator >=(System.Reactive.Concurrency.ScheduledItem left, System.Reactive.Concurrency.ScheduledItem right) { } } public sealed class ScheduledItem : System.Reactive.Concurrency.ScheduledItem where TAbsolute : System.IComparable { public ScheduledItem(System.Reactive.Concurrency.IScheduler scheduler, TValue state, System.Func action, TAbsolute dueTime) { } public ScheduledItem(System.Reactive.Concurrency.IScheduler scheduler, TValue state, System.Func action, TAbsolute dueTime, System.Collections.Generic.IComparer comparer) { } protected override System.IDisposable InvokeCore() { } } public static class Scheduler { public static System.Reactive.Concurrency.CurrentThreadScheduler CurrentThread { get; } public static System.Reactive.Concurrency.DefaultScheduler Default { get; } public static System.Reactive.Concurrency.ImmediateScheduler Immediate { get; } [System.Obsolete("This property is no longer supported due to refactoring of the API surface and el" + "imination of platform-specific dependencies. Please use NewThreadScheduler.Defau" + "lt to obtain an instance of this scheduler type.")] public static System.Reactive.Concurrency.IScheduler NewThread { get; } public static System.DateTimeOffset Now { get; } [System.Obsolete("This property is no longer supported due to refactoring of the API surface and el" + "imination of platform-specific dependencies. Please use TaskPoolScheduler.Defaul" + "t to obtain an instance of this scheduler type.")] public static System.Reactive.Concurrency.IScheduler TaskPool { get; } [System.Obsolete(@"This property is no longer supported due to refactoring of the API surface and elimination of platform-specific dependencies. Consider using Scheduler.Default to obtain the platform's most appropriate pool-based scheduler. In order to access a specific pool-based scheduler, please add a reference to the System.Reactive.PlatformServices assembly for your target platform and use the appropriate scheduler in the System.Reactive.Concurrency namespace.")] public static System.Reactive.Concurrency.IScheduler ThreadPool { get; } public static System.Reactive.Concurrency.ISchedulerLongRunning? AsLongRunning(this System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Reactive.Concurrency.ISchedulerPeriodic? AsPeriodic(this System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Reactive.Concurrency.IStopwatchProvider? AsStopwatchProvider(this System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Reactive.Concurrency.IScheduler Catch(this System.Reactive.Concurrency.IScheduler scheduler, System.Func handler) where TException : System.Exception { } public static System.Reactive.Concurrency.IScheduler DisableOptimizations(this System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Reactive.Concurrency.IScheduler DisableOptimizations(this System.Reactive.Concurrency.IScheduler scheduler, params System.Type[] optimizationInterfaces) { } public static System.TimeSpan Normalize(System.TimeSpan timeSpan) { } public static System.IDisposable Schedule(this System.Reactive.Concurrency.IScheduler scheduler, System.Action action) { } public static System.IDisposable Schedule(this System.Reactive.Concurrency.IScheduler scheduler, System.Action action) { } public static System.IDisposable Schedule(this System.Reactive.Concurrency.IScheduler scheduler, System.DateTimeOffset dueTime, System.Action action) { } public static System.IDisposable Schedule(this System.Reactive.Concurrency.IScheduler scheduler, System.DateTimeOffset dueTime, System.Action> action) { } public static System.IDisposable Schedule(this System.Reactive.Concurrency.IScheduler scheduler, System.TimeSpan dueTime, System.Action action) { } public static System.IDisposable Schedule(this System.Reactive.Concurrency.IScheduler scheduler, System.TimeSpan dueTime, System.Action> action) { } public static System.IDisposable Schedule(this System.Reactive.Concurrency.IScheduler scheduler, TState state, System.Action> action) { } public static System.IDisposable Schedule(this System.Reactive.Concurrency.IScheduler scheduler, TState state, System.DateTimeOffset dueTime, System.Action> action) { } public static System.IDisposable Schedule(this System.Reactive.Concurrency.IScheduler scheduler, TState state, System.TimeSpan dueTime, System.Action> action) { } public static System.IDisposable ScheduleAsync(this System.Reactive.Concurrency.IScheduler scheduler, System.Func action) { } public static System.IDisposable ScheduleAsync(this System.Reactive.Concurrency.IScheduler scheduler, System.Func> action) { } public static System.IDisposable ScheduleAsync(this System.Reactive.Concurrency.IScheduler scheduler, System.DateTimeOffset dueTime, System.Func action) { } public static System.IDisposable ScheduleAsync(this System.Reactive.Concurrency.IScheduler scheduler, System.DateTimeOffset dueTime, System.Func> action) { } public static System.IDisposable ScheduleAsync(this System.Reactive.Concurrency.IScheduler scheduler, System.TimeSpan dueTime, System.Func action) { } public static System.IDisposable ScheduleAsync(this System.Reactive.Concurrency.IScheduler scheduler, System.TimeSpan dueTime, System.Func> action) { } public static System.IDisposable ScheduleAsync(this System.Reactive.Concurrency.IScheduler scheduler, TState state, System.Func action) { } public static System.IDisposable ScheduleAsync(this System.Reactive.Concurrency.IScheduler scheduler, TState state, System.Func> action) { } public static System.IDisposable ScheduleAsync(this System.Reactive.Concurrency.IScheduler scheduler, TState state, System.DateTimeOffset dueTime, System.Func action) { } public static System.IDisposable ScheduleAsync(this System.Reactive.Concurrency.IScheduler scheduler, TState state, System.DateTimeOffset dueTime, System.Func> action) { } public static System.IDisposable ScheduleAsync(this System.Reactive.Concurrency.IScheduler scheduler, TState state, System.TimeSpan dueTime, System.Func action) { } public static System.IDisposable ScheduleAsync(this System.Reactive.Concurrency.IScheduler scheduler, TState state, System.TimeSpan dueTime, System.Func> action) { } public static System.IDisposable ScheduleLongRunning(this System.Reactive.Concurrency.ISchedulerLongRunning scheduler, System.Action action) { } public static System.IDisposable SchedulePeriodic(this System.Reactive.Concurrency.IScheduler scheduler, System.TimeSpan period, System.Action action) { } public static System.IDisposable SchedulePeriodic(this System.Reactive.Concurrency.IScheduler scheduler, TState state, System.TimeSpan period, System.Action action) { } public static System.IDisposable SchedulePeriodic(this System.Reactive.Concurrency.IScheduler scheduler, TState state, System.TimeSpan period, System.Func action) { } public static System.Reactive.Concurrency.SchedulerOperation Sleep(this System.Reactive.Concurrency.IScheduler scheduler, System.DateTimeOffset dueTime) { } public static System.Reactive.Concurrency.SchedulerOperation Sleep(this System.Reactive.Concurrency.IScheduler scheduler, System.TimeSpan dueTime) { } public static System.Reactive.Concurrency.SchedulerOperation Sleep(this System.Reactive.Concurrency.IScheduler scheduler, System.DateTimeOffset dueTime, System.Threading.CancellationToken cancellationToken) { } public static System.Reactive.Concurrency.SchedulerOperation Sleep(this System.Reactive.Concurrency.IScheduler scheduler, System.TimeSpan dueTime, System.Threading.CancellationToken cancellationToken) { } public static System.Reactive.Concurrency.IStopwatch StartStopwatch(this System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Reactive.Concurrency.SchedulerOperation Yield(this System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Reactive.Concurrency.SchedulerOperation Yield(this System.Reactive.Concurrency.IScheduler scheduler, System.Threading.CancellationToken cancellationToken) { } } public sealed class SchedulerOperation { public System.Reactive.Concurrency.SchedulerOperation ConfigureAwait(bool continueOnCapturedContext) { } public System.Reactive.Concurrency.SchedulerOperationAwaiter GetAwaiter() { } } public sealed class SchedulerOperationAwaiter : System.Runtime.CompilerServices.INotifyCompletion { public bool IsCompleted { get; } public void GetResult() { } public void OnCompleted(System.Action continuation) { } } public class SchedulerQueue where TAbsolute : System.IComparable { public SchedulerQueue() { } public SchedulerQueue(int capacity) { } public int Count { get; } public System.Reactive.Concurrency.ScheduledItem Dequeue() { } public void Enqueue(System.Reactive.Concurrency.ScheduledItem scheduledItem) { } public System.Reactive.Concurrency.ScheduledItem Peek() { } public bool Remove(System.Reactive.Concurrency.ScheduledItem scheduledItem) { } } public static class Synchronization { public static System.IObservable ObserveOn(System.IObservable source, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.IObservable ObserveOn(System.IObservable source, System.Threading.SynchronizationContext context) { } public static System.IObservable SubscribeOn(System.IObservable source, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.IObservable SubscribeOn(System.IObservable source, System.Threading.SynchronizationContext context) { } public static System.IObservable Synchronize(System.IObservable source) { } public static System.IObservable Synchronize(System.IObservable source, object gate) { } } public class SynchronizationContextScheduler : System.Reactive.Concurrency.LocalScheduler { public SynchronizationContextScheduler(System.Threading.SynchronizationContext context) { } public SynchronizationContextScheduler(System.Threading.SynchronizationContext context, bool alwaysPost) { } public override System.IDisposable Schedule(TState state, System.Func action) { } public override System.IDisposable Schedule(TState state, System.TimeSpan dueTime, System.Func action) { } } public sealed class TaskObservationOptions { public TaskObservationOptions(System.Reactive.Concurrency.IScheduler? scheduler, bool ignoreExceptionsAfterUnsubscribe) { } public bool IgnoreExceptionsAfterUnsubscribe { get; } public System.Reactive.Concurrency.IScheduler? Scheduler { get; } } public sealed class TaskPoolScheduler : System.Reactive.Concurrency.LocalScheduler, System.Reactive.Concurrency.ISchedulerLongRunning, System.Reactive.Concurrency.ISchedulerPeriodic { public TaskPoolScheduler(System.Threading.Tasks.TaskFactory taskFactory) { } public static System.Reactive.Concurrency.TaskPoolScheduler Default { get; } public override System.IDisposable Schedule(TState state, System.Func action) { } public override System.IDisposable Schedule(TState state, System.TimeSpan dueTime, System.Func action) { } public System.IDisposable ScheduleLongRunning(TState state, System.Action action) { } public System.IDisposable SchedulePeriodic(TState state, System.TimeSpan period, System.Func action) { } public override System.Reactive.Concurrency.IStopwatch StartStopwatch() { } } public sealed class ThreadPoolScheduler : System.Reactive.Concurrency.LocalScheduler, System.Reactive.Concurrency.ISchedulerLongRunning, System.Reactive.Concurrency.ISchedulerPeriodic { public static System.Reactive.Concurrency.ThreadPoolScheduler Instance { get; } public override System.IDisposable Schedule(TState state, System.Func action) { } public override System.IDisposable Schedule(TState state, System.TimeSpan dueTime, System.Func action) { } public System.IDisposable ScheduleLongRunning(TState state, System.Action action) { } public System.IDisposable SchedulePeriodic(TState state, System.TimeSpan period, System.Func action) { } public override System.Reactive.Concurrency.IStopwatch StartStopwatch() { } } public abstract class VirtualTimeSchedulerBase : System.IServiceProvider, System.Reactive.Concurrency.IScheduler, System.Reactive.Concurrency.IStopwatchProvider where TAbsolute : System.IComparable { protected VirtualTimeSchedulerBase() { } protected VirtualTimeSchedulerBase(TAbsolute initialClock, System.Collections.Generic.IComparer comparer) { } public TAbsolute Clock { get; set; } protected System.Collections.Generic.IComparer Comparer { get; } public bool IsEnabled { get; } public System.DateTimeOffset Now { get; } protected abstract TAbsolute Add(TAbsolute absolute, TRelative relative); public void AdvanceBy(TRelative time) { } public void AdvanceTo(TAbsolute time) { } protected abstract System.Reactive.Concurrency.IScheduledItem? GetNext(); protected virtual object? GetService(System.Type serviceType) { } public System.IDisposable Schedule(TState state, System.Func action) { } public System.IDisposable Schedule(TState state, System.DateTimeOffset dueTime, System.Func action) { } public System.IDisposable Schedule(TState state, System.TimeSpan dueTime, System.Func action) { } public abstract System.IDisposable ScheduleAbsolute(TState state, TAbsolute dueTime, System.Func action); public System.IDisposable ScheduleRelative(TState state, TRelative dueTime, System.Func action) { } public void Sleep(TRelative time) { } public void Start() { } public System.Reactive.Concurrency.IStopwatch StartStopwatch() { } public void Stop() { } protected abstract System.DateTimeOffset ToDateTimeOffset(TAbsolute absolute); protected abstract TRelative ToRelative(System.TimeSpan timeSpan); } public static class VirtualTimeSchedulerExtensions { public static System.IDisposable ScheduleAbsolute(this System.Reactive.Concurrency.VirtualTimeSchedulerBase scheduler, TAbsolute dueTime, System.Action action) where TAbsolute : System.IComparable { } public static System.IDisposable ScheduleRelative(this System.Reactive.Concurrency.VirtualTimeSchedulerBase scheduler, TRelative dueTime, System.Action action) where TAbsolute : System.IComparable { } } public abstract class VirtualTimeScheduler : System.Reactive.Concurrency.VirtualTimeSchedulerBase where TAbsolute : System.IComparable { protected VirtualTimeScheduler() { } protected VirtualTimeScheduler(TAbsolute initialClock, System.Collections.Generic.IComparer comparer) { } protected override System.Reactive.Concurrency.IScheduledItem? GetNext() { } public override System.IDisposable ScheduleAbsolute(TState state, TAbsolute dueTime, System.Func action) { } } } namespace System.Reactive.Disposables { public sealed class BooleanDisposable : System.IDisposable, System.Reactive.Disposables.ICancelable { public BooleanDisposable() { } public bool IsDisposed { get; } public void Dispose() { } } public sealed class CancellationDisposable : System.IDisposable, System.Reactive.Disposables.ICancelable { public CancellationDisposable() { } public CancellationDisposable(System.Threading.CancellationTokenSource cts) { } public bool IsDisposed { get; } public System.Threading.CancellationToken Token { get; } public void Dispose() { } } public sealed class CompositeDisposable : System.Collections.Generic.ICollection, System.Collections.Generic.IEnumerable, System.Collections.IEnumerable, System.IDisposable, System.Reactive.Disposables.ICancelable { public CompositeDisposable() { } public CompositeDisposable(System.Collections.Generic.IEnumerable disposables) { } public CompositeDisposable(params System.IDisposable[] disposables) { } public CompositeDisposable(int capacity) { } public int Count { get; } public bool IsDisposed { get; } public bool IsReadOnly { get; } public void Add(System.IDisposable item) { } public void Clear() { } public bool Contains(System.IDisposable item) { } public void CopyTo(System.IDisposable[] array, int arrayIndex) { } public void Dispose() { } public System.Collections.Generic.IEnumerator GetEnumerator() { } public bool Remove(System.IDisposable item) { } } public sealed class ContextDisposable : System.IDisposable, System.Reactive.Disposables.ICancelable { public ContextDisposable(System.Threading.SynchronizationContext context, System.IDisposable disposable) { } public System.Threading.SynchronizationContext Context { get; } public bool IsDisposed { get; } public void Dispose() { } } public static class Disposable { public static System.IDisposable Empty { get; } public static System.IDisposable Create(System.Action dispose) { } public static System.IDisposable Create(TState state, System.Action dispose) { } } public interface ICancelable : System.IDisposable { bool IsDisposed { get; } } public sealed class MultipleAssignmentDisposable : System.IDisposable, System.Reactive.Disposables.ICancelable { public MultipleAssignmentDisposable() { } public System.IDisposable? Disposable { get; set; } public bool IsDisposed { get; } public void Dispose() { } } public sealed class RefCountDisposable : System.IDisposable, System.Reactive.Disposables.ICancelable { public RefCountDisposable(System.IDisposable disposable) { } public RefCountDisposable(System.IDisposable disposable, bool throwWhenDisposed) { } public bool IsDisposed { get; } public void Dispose() { } public System.IDisposable GetDisposable() { } } public sealed class ScheduledDisposable : System.IDisposable, System.Reactive.Disposables.ICancelable { public ScheduledDisposable(System.Reactive.Concurrency.IScheduler scheduler, System.IDisposable disposable) { } public System.IDisposable Disposable { get; } public bool IsDisposed { get; } public System.Reactive.Concurrency.IScheduler Scheduler { get; } public void Dispose() { } } public sealed class SerialDisposable : System.IDisposable, System.Reactive.Disposables.ICancelable { public SerialDisposable() { } public System.IDisposable? Disposable { get; set; } public bool IsDisposed { get; } public void Dispose() { } } public sealed class SingleAssignmentDisposable : System.IDisposable, System.Reactive.Disposables.ICancelable { public SingleAssignmentDisposable() { } public System.IDisposable? Disposable { get; set; } public bool IsDisposed { get; } public void Dispose() { } } public struct SingleAssignmentDisposableValue { public System.IDisposable? Disposable { get; set; } public bool IsDisposed { get; } public void Dispose() { } public override bool Equals(object? obj) { } public override int GetHashCode() { } public static bool operator !=(System.Reactive.Disposables.SingleAssignmentDisposableValue left, System.Reactive.Disposables.SingleAssignmentDisposableValue right) { } public static bool operator ==(System.Reactive.Disposables.SingleAssignmentDisposableValue left, System.Reactive.Disposables.SingleAssignmentDisposableValue right) { } } public abstract class StableCompositeDisposable : System.IDisposable, System.Reactive.Disposables.ICancelable { protected StableCompositeDisposable() { } public abstract bool IsDisposed { get; } public abstract void Dispose(); public static System.Reactive.Disposables.ICancelable Create(System.Collections.Generic.IEnumerable disposables) { } public static System.Reactive.Disposables.ICancelable Create(params System.IDisposable[] disposables) { } public static System.Reactive.Disposables.ICancelable Create(System.IDisposable disposable1, System.IDisposable disposable2) { } } } namespace System.Reactive.Disposables.Fluent { public static class DisposableExtensions { public static T DisposeWith(this T item, System.Reactive.Disposables.CompositeDisposable compositeDisposable) where T : System.IDisposable { } } } namespace System.Reactive.Joins { public abstract class Pattern { } public class Pattern : System.Reactive.Joins.Pattern { public System.Reactive.Joins.Plan Then(System.Func selector) { } } public class Pattern : System.Reactive.Joins.Pattern { public System.Reactive.Joins.Pattern And(System.IObservable other) { } public System.Reactive.Joins.Plan Then(System.Func selector) { } } public class Pattern : System.Reactive.Joins.Pattern { public System.Reactive.Joins.Pattern And(System.IObservable other) { } public System.Reactive.Joins.Plan Then(System.Func selector) { } } public class Pattern : System.Reactive.Joins.Pattern { public System.Reactive.Joins.Pattern And(System.IObservable other) { } public System.Reactive.Joins.Plan Then(System.Func selector) { } } public class Pattern : System.Reactive.Joins.Pattern { public System.Reactive.Joins.Pattern And(System.IObservable other) { } public System.Reactive.Joins.Plan Then(System.Func selector) { } } public class Pattern : System.Reactive.Joins.Pattern { public System.Reactive.Joins.Pattern And(System.IObservable other) { } public System.Reactive.Joins.Plan Then(System.Func selector) { } } public class Pattern : System.Reactive.Joins.Pattern { public System.Reactive.Joins.Pattern And(System.IObservable other) { } public System.Reactive.Joins.Plan Then(System.Func selector) { } } public class Pattern : System.Reactive.Joins.Pattern { public System.Reactive.Joins.Plan Then(System.Func selector) { } } public class Pattern : System.Reactive.Joins.Pattern { public System.Reactive.Joins.Pattern And(System.IObservable other) { } public System.Reactive.Joins.Plan Then(System.Func selector) { } } public class Pattern : System.Reactive.Joins.Pattern { public System.Reactive.Joins.Pattern And(System.IObservable other) { } public System.Reactive.Joins.Plan Then(System.Func selector) { } } public class Pattern : System.Reactive.Joins.Pattern { public System.Reactive.Joins.Pattern And(System.IObservable other) { } public System.Reactive.Joins.Plan Then(System.Func selector) { } } public class Pattern : System.Reactive.Joins.Pattern { public System.Reactive.Joins.Pattern And(System.IObservable other) { } public System.Reactive.Joins.Plan Then(System.Func selector) { } } public class Pattern : System.Reactive.Joins.Pattern { public System.Reactive.Joins.Pattern And(System.IObservable other) { } public System.Reactive.Joins.Plan Then(System.Func selector) { } } public class Pattern : System.Reactive.Joins.Pattern { public System.Reactive.Joins.Pattern And(System.IObservable other) { } public System.Reactive.Joins.Plan Then(System.Func selector) { } } public class Pattern : System.Reactive.Joins.Pattern { public System.Reactive.Joins.Pattern And(System.IObservable other) { } public System.Reactive.Joins.Plan Then(System.Func selector) { } } public class Pattern : System.Reactive.Joins.Pattern { public System.Reactive.Joins.Pattern And(System.IObservable other) { } public System.Reactive.Joins.Plan Then(System.Func selector) { } } public abstract class Plan { } public abstract class QueryablePattern { protected QueryablePattern(System.Linq.Expressions.Expression expression) { } public System.Linq.Expressions.Expression Expression { get; } } public class QueryablePattern : System.Reactive.Joins.QueryablePattern { public System.Reactive.Joins.QueryablePattern And(System.IObservable other) { } public System.Reactive.Joins.QueryablePlan Then(System.Linq.Expressions.Expression> selector) { } } public class QueryablePattern : System.Reactive.Joins.QueryablePattern { public System.Reactive.Joins.QueryablePattern And(System.IObservable other) { } public System.Reactive.Joins.QueryablePlan Then(System.Linq.Expressions.Expression> selector) { } } public class QueryablePattern : System.Reactive.Joins.QueryablePattern { public System.Reactive.Joins.QueryablePattern And(System.IObservable other) { } public System.Reactive.Joins.QueryablePlan Then(System.Linq.Expressions.Expression> selector) { } } public class QueryablePattern : System.Reactive.Joins.QueryablePattern { public System.Reactive.Joins.QueryablePattern And(System.IObservable other) { } public System.Reactive.Joins.QueryablePlan Then(System.Linq.Expressions.Expression> selector) { } } public class QueryablePattern : System.Reactive.Joins.QueryablePattern { public System.Reactive.Joins.QueryablePattern And(System.IObservable other) { } public System.Reactive.Joins.QueryablePlan Then(System.Linq.Expressions.Expression> selector) { } } public class QueryablePattern : System.Reactive.Joins.QueryablePattern { public System.Reactive.Joins.QueryablePattern And(System.IObservable other) { } public System.Reactive.Joins.QueryablePlan Then(System.Linq.Expressions.Expression> selector) { } } public class QueryablePattern : System.Reactive.Joins.QueryablePattern { public System.Reactive.Joins.QueryablePlan Then(System.Linq.Expressions.Expression> selector) { } } public class QueryablePattern : System.Reactive.Joins.QueryablePattern { public System.Reactive.Joins.QueryablePattern And(System.IObservable other) { } public System.Reactive.Joins.QueryablePlan Then(System.Linq.Expressions.Expression> selector) { } } public class QueryablePattern : System.Reactive.Joins.QueryablePattern { public System.Reactive.Joins.QueryablePattern And(System.IObservable other) { } public System.Reactive.Joins.QueryablePlan Then(System.Linq.Expressions.Expression> selector) { } } public class QueryablePattern : System.Reactive.Joins.QueryablePattern { public System.Reactive.Joins.QueryablePattern And(System.IObservable other) { } public System.Reactive.Joins.QueryablePlan Then(System.Linq.Expressions.Expression> selector) { } } public class QueryablePattern : System.Reactive.Joins.QueryablePattern { public System.Reactive.Joins.QueryablePattern And(System.IObservable other) { } public System.Reactive.Joins.QueryablePlan Then(System.Linq.Expressions.Expression> selector) { } } public class QueryablePattern : System.Reactive.Joins.QueryablePattern { public System.Reactive.Joins.QueryablePattern And(System.IObservable other) { } public System.Reactive.Joins.QueryablePlan Then(System.Linq.Expressions.Expression> selector) { } } public class QueryablePattern : System.Reactive.Joins.QueryablePattern { public System.Reactive.Joins.QueryablePattern And(System.IObservable other) { } public System.Reactive.Joins.QueryablePlan Then(System.Linq.Expressions.Expression> selector) { } } public class QueryablePattern : System.Reactive.Joins.QueryablePattern { public System.Reactive.Joins.QueryablePattern And(System.IObservable other) { } public System.Reactive.Joins.QueryablePlan Then(System.Linq.Expressions.Expression> selector) { } } public class QueryablePattern : System.Reactive.Joins.QueryablePattern { public System.Reactive.Joins.QueryablePattern And(System.IObservable other) { } public System.Reactive.Joins.QueryablePlan Then(System.Linq.Expressions.Expression> selector) { } } public class QueryablePlan { public System.Linq.Expressions.Expression Expression { get; } } } namespace System.Reactive.Linq { public static class ControlObservable { public static System.IObservable ObserveOn(this System.IObservable source, System.Windows.Forms.Control control) { } public static System.IObservable SubscribeOn(this System.IObservable source, System.Windows.Forms.Control control) { } } public static class DispatcherObservable { public static System.IObservable ObserveOn(this System.IObservable source, System.Reactive.Concurrency.DispatcherScheduler scheduler) { } public static System.IObservable ObserveOn(this System.IObservable source, System.Windows.Threading.Dispatcher dispatcher) { } public static System.IObservable ObserveOn(this System.IObservable source, System.Windows.Threading.DispatcherObject dispatcherObject) { } public static System.IObservable ObserveOn(this System.IObservable source, System.Windows.Threading.Dispatcher dispatcher, System.Windows.Threading.DispatcherPriority priority) { } public static System.IObservable ObserveOn(this System.IObservable source, System.Windows.Threading.DispatcherObject dispatcherObject, System.Windows.Threading.DispatcherPriority priority) { } public static System.IObservable ObserveOnDispatcher(this System.IObservable source) { } public static System.IObservable ObserveOnDispatcher(this System.IObservable source, System.Windows.Threading.DispatcherPriority priority) { } public static System.IObservable SubscribeOn(this System.IObservable source, System.Reactive.Concurrency.DispatcherScheduler scheduler) { } public static System.IObservable SubscribeOn(this System.IObservable source, System.Windows.Threading.Dispatcher dispatcher) { } public static System.IObservable SubscribeOn(this System.IObservable source, System.Windows.Threading.DispatcherObject dispatcherObject) { } public static System.IObservable SubscribeOn(this System.IObservable source, System.Windows.Threading.Dispatcher dispatcher, System.Windows.Threading.DispatcherPriority priority) { } public static System.IObservable SubscribeOn(this System.IObservable source, System.Windows.Threading.DispatcherObject dispatcherObject, System.Windows.Threading.DispatcherPriority priority) { } public static System.IObservable SubscribeOnDispatcher(this System.IObservable source) { } public static System.IObservable SubscribeOnDispatcher(this System.IObservable source, System.Windows.Threading.DispatcherPriority priority) { } } public interface IGroupedObservable : System.IObservable { TKey Key { get; } } public interface IQbservable { System.Type ElementType { get; } System.Linq.Expressions.Expression Expression { get; } System.Reactive.Linq.IQbservableProvider Provider { get; } } public interface IQbservableProvider { System.Reactive.Linq.IQbservable CreateQuery(System.Linq.Expressions.Expression expression); } public interface IQbservable : System.IObservable, System.Reactive.Linq.IQbservable { } [System.AttributeUsage(System.AttributeTargets.Class, Inherited=false)] public sealed class LocalQueryMethodImplementationTypeAttribute : System.Attribute { public LocalQueryMethodImplementationTypeAttribute(System.Type targetType) { } public System.Type TargetType { get; } } public static class Observable { public static System.IObservable Aggregate(this System.IObservable source, System.Func accumulator) { } public static System.IObservable Aggregate(this System.IObservable source, TAccumulate seed, System.Func accumulator) { } public static System.IObservable Aggregate(this System.IObservable source, TAccumulate seed, System.Func accumulator, System.Func resultSelector) { } public static System.IObservable All(this System.IObservable source, System.Func predicate) { } public static System.IObservable Amb(params System.IObservable[] sources) { } public static System.IObservable Amb(this System.Collections.Generic.IEnumerable> sources) { } public static System.IObservable Amb(this System.IObservable first, System.IObservable second) { } public static System.Reactive.Joins.Pattern And(this System.IObservable left, System.IObservable right) { } public static System.IObservable Any(this System.IObservable source) { } public static System.IObservable Any(this System.IObservable source, System.Func predicate) { } public static System.IObservable Append(this System.IObservable source, TSource value) { } public static System.IObservable Append(this System.IObservable source, TSource value, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.IObservable AsObservable(this System.IObservable source) { } public static System.IObservable AutoConnect(this System.Reactive.Subjects.IConnectableObservable source, int minObservers = 1, System.Action? onConnect = null) { } public static System.IObservable Average(this System.IObservable source) { } public static System.IObservable Average(this System.IObservable source) { } public static System.IObservable Average(this System.IObservable source) { } public static System.IObservable Average(this System.IObservable source) { } public static System.IObservable Average(this System.IObservable source) { } public static System.IObservable Average(this System.IObservable source) { } public static System.IObservable Average(this System.IObservable source) { } public static System.IObservable Average(this System.IObservable source) { } public static System.IObservable Average(this System.IObservable source) { } public static System.IObservable Average(this System.IObservable source) { } public static System.IObservable Average(this System.IObservable source, System.Func selector) { } public static System.IObservable Average(this System.IObservable source, System.Func selector) { } public static System.IObservable Average(this System.IObservable source, System.Func selector) { } public static System.IObservable Average(this System.IObservable source, System.Func selector) { } public static System.IObservable Average(this System.IObservable source, System.Func selector) { } public static System.IObservable Average(this System.IObservable source, System.Func selector) { } public static System.IObservable Average(this System.IObservable source, System.Func selector) { } public static System.IObservable Average(this System.IObservable source, System.Func selector) { } public static System.IObservable Average(this System.IObservable source, System.Func selector) { } public static System.IObservable Average(this System.IObservable source, System.Func selector) { } public static System.IObservable> Buffer(this System.IObservable source, int count) { } public static System.IObservable> Buffer(this System.IObservable source, System.TimeSpan timeSpan) { } public static System.IObservable> Buffer(this System.IObservable source, int count, int skip) { } public static System.IObservable> Buffer(this System.IObservable source, System.TimeSpan timeSpan, int count) { } public static System.IObservable> Buffer(this System.IObservable source, System.TimeSpan timeSpan, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.IObservable> Buffer(this System.IObservable source, System.TimeSpan timeSpan, System.TimeSpan timeShift) { } public static System.IObservable> Buffer(this System.IObservable source, System.TimeSpan timeSpan, int count, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.IObservable> Buffer(this System.IObservable source, System.TimeSpan timeSpan, System.TimeSpan timeShift, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.IObservable> Buffer(this System.IObservable source, System.Func> bufferClosingSelector) { } public static System.IObservable> Buffer(this System.IObservable source, System.IObservable bufferBoundaries) { } public static System.IObservable> Buffer(this System.IObservable source, System.IObservable bufferOpenings, System.Func> bufferClosingSelector) { } public static System.IObservable Case(System.Func selector, System.Collections.Generic.IDictionary> sources) where TValue : notnull { } public static System.IObservable Case(System.Func selector, System.Collections.Generic.IDictionary> sources, System.IObservable defaultSource) where TValue : notnull { } public static System.IObservable Case(System.Func selector, System.Collections.Generic.IDictionary> sources, System.Reactive.Concurrency.IScheduler scheduler) where TValue : notnull { } public static System.IObservable Cast(this System.IObservable source) { } public static System.IObservable Catch(params System.IObservable[] sources) { } public static System.IObservable Catch(this System.Collections.Generic.IEnumerable> sources) { } public static System.IObservable Catch(this System.IObservable first, System.IObservable second) { } public static System.IObservable Catch(this System.IObservable source, System.Func> handler) where TException : System.Exception { } public static System.Collections.Generic.IEnumerable> Chunkify(this System.IObservable source) { } public static System.Collections.Generic.IEnumerable Collect(this System.IObservable source, System.Func newCollector, System.Func merge) { } public static System.Collections.Generic.IEnumerable Collect(this System.IObservable source, System.Func getInitialCollector, System.Func merge, System.Func getNewCollector) { } public static System.IObservable> CombineLatest(params System.IObservable[] sources) { } public static System.IObservable> CombineLatest(this System.Collections.Generic.IEnumerable> sources) { } public static System.IObservable CombineLatest(this System.Collections.Generic.IEnumerable> sources, System.Func, TResult> resultSelector) { } public static System.IObservable CombineLatest(this System.IObservable first, System.IObservable second, System.Func resultSelector) { } public static System.IObservable CombineLatest(this System.IObservable source1, System.IObservable source2, System.IObservable source3, System.Func resultSelector) { } public static System.IObservable CombineLatest(this System.IObservable source1, System.IObservable source2, System.IObservable source3, System.IObservable source4, System.Func resultSelector) { } public static System.IObservable CombineLatest(this System.IObservable source1, System.IObservable source2, System.IObservable source3, System.IObservable source4, System.IObservable source5, System.Func resultSelector) { } public static System.IObservable CombineLatest(this System.IObservable source1, System.IObservable source2, System.IObservable source3, System.IObservable source4, System.IObservable source5, System.IObservable source6, System.Func resultSelector) { } public static System.IObservable CombineLatest(this System.IObservable source1, System.IObservable source2, System.IObservable source3, System.IObservable source4, System.IObservable source5, System.IObservable source6, System.IObservable source7, System.Func resultSelector) { } public static System.IObservable CombineLatest(this System.IObservable source1, System.IObservable source2, System.IObservable source3, System.IObservable source4, System.IObservable source5, System.IObservable source6, System.IObservable source7, System.IObservable source8, System.Func resultSelector) { } public static System.IObservable CombineLatest(this System.IObservable source1, System.IObservable source2, System.IObservable source3, System.IObservable source4, System.IObservable source5, System.IObservable source6, System.IObservable source7, System.IObservable source8, System.IObservable source9, System.Func resultSelector) { } public static System.IObservable CombineLatest(this System.IObservable source1, System.IObservable source2, System.IObservable source3, System.IObservable source4, System.IObservable source5, System.IObservable source6, System.IObservable source7, System.IObservable source8, System.IObservable source9, System.IObservable source10, System.Func resultSelector) { } public static System.IObservable CombineLatest(this System.IObservable source1, System.IObservable source2, System.IObservable source3, System.IObservable source4, System.IObservable source5, System.IObservable source6, System.IObservable source7, System.IObservable source8, System.IObservable source9, System.IObservable source10, System.IObservable source11, System.Func resultSelector) { } public static System.IObservable CombineLatest(this System.IObservable source1, System.IObservable source2, System.IObservable source3, System.IObservable source4, System.IObservable source5, System.IObservable source6, System.IObservable source7, System.IObservable source8, System.IObservable source9, System.IObservable source10, System.IObservable source11, System.IObservable source12, System.Func resultSelector) { } public static System.IObservable CombineLatest(this System.IObservable source1, System.IObservable source2, System.IObservable source3, System.IObservable source4, System.IObservable source5, System.IObservable source6, System.IObservable source7, System.IObservable source8, System.IObservable source9, System.IObservable source10, System.IObservable source11, System.IObservable source12, System.IObservable source13, System.Func resultSelector) { } public static System.IObservable CombineLatest(this System.IObservable source1, System.IObservable source2, System.IObservable source3, System.IObservable source4, System.IObservable source5, System.IObservable source6, System.IObservable source7, System.IObservable source8, System.IObservable source9, System.IObservable source10, System.IObservable source11, System.IObservable source12, System.IObservable source13, System.IObservable source14, System.Func resultSelector) { } public static System.IObservable CombineLatest( this System.IObservable source1, System.IObservable source2, System.IObservable source3, System.IObservable source4, System.IObservable source5, System.IObservable source6, System.IObservable source7, System.IObservable source8, System.IObservable source9, System.IObservable source10, System.IObservable source11, System.IObservable source12, System.IObservable source13, System.IObservable source14, System.IObservable source15, System.Func resultSelector) { } public static System.IObservable CombineLatest( this System.IObservable source1, System.IObservable source2, System.IObservable source3, System.IObservable source4, System.IObservable source5, System.IObservable source6, System.IObservable source7, System.IObservable source8, System.IObservable source9, System.IObservable source10, System.IObservable source11, System.IObservable source12, System.IObservable source13, System.IObservable source14, System.IObservable source15, System.IObservable source16, System.Func resultSelector) { } public static System.IObservable Concat(params System.IObservable[] sources) { } public static System.IObservable Concat(this System.Collections.Generic.IEnumerable> sources) { } public static System.IObservable Concat(this System.IObservable> sources) { } public static System.IObservable Concat(this System.IObservable> sources) { } public static System.IObservable Concat(this System.IObservable first, System.IObservable second) { } public static System.IObservable Contains(this System.IObservable source, TSource value) { } public static System.IObservable Contains(this System.IObservable source, TSource value, System.Collections.Generic.IEqualityComparer comparer) { } public static System.IObservable Count(this System.IObservable source) { } public static System.IObservable Count(this System.IObservable source, System.Func predicate) { } public static System.IObservable Create(System.Func, System.Action> subscribe) { } public static System.IObservable Create(System.Func, System.IDisposable> subscribe) { } public static System.IObservable Create(System.Func, System.Threading.Tasks.Task> subscribeAsync) { } public static System.IObservable Create(System.Func, System.Threading.Tasks.Task> subscribeAsync) { } public static System.IObservable Create(System.Func, System.Threading.Tasks.Task> subscribeAsync) { } public static System.IObservable Create(System.Func, System.Threading.CancellationToken, System.Threading.Tasks.Task> subscribeAsync) { } public static System.IObservable Create(System.Func, System.Threading.CancellationToken, System.Threading.Tasks.Task> subscribeAsync) { } public static System.IObservable Create(System.Func, System.Threading.CancellationToken, System.Threading.Tasks.Task> subscribeAsync) { } public static System.IObservable DefaultIfEmpty(this System.IObservable source) { } public static System.IObservable DefaultIfEmpty(this System.IObservable source, TSource defaultValue) { } public static System.IObservable Defer(System.Func> observableFactory) { } public static System.IObservable Defer(System.Func>> observableFactoryAsync) { } public static System.IObservable Defer(System.Func>> observableFactoryAsync, bool ignoreExceptionsAfterUnsubscribe) { } public static System.IObservable DeferAsync(System.Func>> observableFactoryAsync) { } public static System.IObservable DeferAsync(System.Func>> observableFactoryAsync, bool ignoreExceptionsAfterUnsubscribe) { } public static System.IObservable Delay(this System.IObservable source, System.DateTimeOffset dueTime) { } public static System.IObservable Delay(this System.IObservable source, System.TimeSpan dueTime) { } public static System.IObservable Delay(this System.IObservable source, System.DateTimeOffset dueTime, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.IObservable Delay(this System.IObservable source, System.TimeSpan dueTime, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.IObservable Delay(this System.IObservable source, System.Func> delayDurationSelector) { } public static System.IObservable Delay(this System.IObservable source, System.IObservable subscriptionDelay, System.Func> delayDurationSelector) { } public static System.IObservable DelaySubscription(this System.IObservable source, System.DateTimeOffset dueTime) { } public static System.IObservable DelaySubscription(this System.IObservable source, System.TimeSpan dueTime) { } public static System.IObservable DelaySubscription(this System.IObservable source, System.DateTimeOffset dueTime, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.IObservable DelaySubscription(this System.IObservable source, System.TimeSpan dueTime, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.IObservable Dematerialize(this System.IObservable> source) { } public static System.IObservable Distinct(this System.IObservable source) { } public static System.IObservable Distinct(this System.IObservable source, System.Collections.Generic.IEqualityComparer comparer) { } public static System.IObservable Distinct(this System.IObservable source, System.Func keySelector) { } public static System.IObservable Distinct(this System.IObservable source, System.Func keySelector, System.Collections.Generic.IEqualityComparer comparer) { } public static System.IObservable DistinctUntilChanged(this System.IObservable source) { } public static System.IObservable DistinctUntilChanged(this System.IObservable source, System.Collections.Generic.IEqualityComparer comparer) { } public static System.IObservable DistinctUntilChanged(this System.IObservable source, System.Func keySelector) { } public static System.IObservable DistinctUntilChanged(this System.IObservable source, System.Func keySelector, System.Collections.Generic.IEqualityComparer comparer) { } public static System.IObservable Do(this System.IObservable source, System.Action onNext) { } public static System.IObservable Do(this System.IObservable source, System.IObserver observer) { } public static System.IObservable Do(this System.IObservable source, System.Action onNext, System.Action onCompleted) { } public static System.IObservable Do(this System.IObservable source, System.Action onNext, System.Action onError) { } public static System.IObservable Do(this System.IObservable source, System.Action onNext, System.Action onError, System.Action onCompleted) { } public static System.IObservable DoWhile(this System.IObservable source, System.Func condition) { } public static System.IObservable ElementAt(this System.IObservable source, int index) { } public static System.IObservable ElementAtOrDefault(this System.IObservable source, int index) { } public static System.IObservable Empty() { } public static System.IObservable Empty(System.Reactive.Concurrency.IScheduler scheduler) { } public static System.IObservable Empty(TResult witness) { } public static System.IObservable Empty(System.Reactive.Concurrency.IScheduler scheduler, TResult witness) { } public static System.IObservable Finally(this System.IObservable source, System.Action finallyAction) { } [System.Obsolete(@"This blocking operation is no longer supported. Instead, use the async version in combination with C# and Visual Basic async/await support. In case you need a blocking operation, use Wait or convert the resulting observable sequence to a Task object and block.")] public static TSource First(this System.IObservable source) { } [System.Obsolete(@"This blocking operation is no longer supported. Instead, use the async version in combination with C# and Visual Basic async/await support. In case you need a blocking operation, use Wait or convert the resulting observable sequence to a Task object and block.")] public static TSource First(this System.IObservable source, System.Func predicate) { } public static System.IObservable FirstAsync(this System.IObservable source) { } public static System.IObservable FirstAsync(this System.IObservable source, System.Func predicate) { } [System.Obsolete(@"This blocking operation is no longer supported. Instead, use the async version in combination with C# and Visual Basic async/await support. In case you need a blocking operation, use Wait or convert the resulting observable sequence to a Task object and block.")] [return: System.Diagnostics.CodeAnalysis.MaybeNull] public static TSource FirstOrDefault(this System.IObservable source) { } [System.Obsolete(@"This blocking operation is no longer supported. Instead, use the async version in combination with C# and Visual Basic async/await support. In case you need a blocking operation, use Wait or convert the resulting observable sequence to a Task object and block.")] [return: System.Diagnostics.CodeAnalysis.MaybeNull] public static TSource FirstOrDefault(this System.IObservable source, System.Func predicate) { } public static System.IObservable FirstOrDefaultAsync(this System.IObservable source) { } public static System.IObservable FirstOrDefaultAsync(this System.IObservable source, System.Func predicate) { } public static System.IObservable For(System.Collections.Generic.IEnumerable source, System.Func> resultSelector) { } [System.Obsolete(@"This blocking operation is no longer supported. Instead, use the async version in combination with C# and Visual Basic async/await support. In case you need a blocking operation, use Wait or convert the resulting observable sequence to a Task object and block.")] public static void ForEach(this System.IObservable source, System.Action onNext) { } [System.Obsolete(@"This blocking operation is no longer supported. Instead, use the async version in combination with C# and Visual Basic async/await support. In case you need a blocking operation, use Wait or convert the resulting observable sequence to a Task object and block.")] public static void ForEach(this System.IObservable source, System.Action onNext) { } public static System.Threading.Tasks.Task ForEachAsync(this System.IObservable source, System.Action onNext) { } public static System.Threading.Tasks.Task ForEachAsync(this System.IObservable source, System.Action onNext) { } public static System.Threading.Tasks.Task ForEachAsync(this System.IObservable source, System.Action onNext, System.Threading.CancellationToken cancellationToken) { } public static System.Threading.Tasks.Task ForEachAsync(this System.IObservable source, System.Action onNext, System.Threading.CancellationToken cancellationToken) { } public static System.IObservable FromAsync(System.Func actionAsync) { } public static System.IObservable FromAsync(System.Func actionAsync) { } public static System.IObservable FromAsync(System.Func actionAsync, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.IObservable FromAsync(System.Func actionAsync, System.Reactive.Concurrency.TaskObservationOptions options) { } public static System.IObservable FromAsync(System.Func actionAsync, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.IObservable FromAsync(System.Func actionAsync, System.Reactive.Concurrency.TaskObservationOptions options) { } public static System.IObservable FromAsync(System.Func> functionAsync) { } public static System.IObservable FromAsync(System.Func> functionAsync) { } public static System.IObservable FromAsync(System.Func> functionAsync, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.IObservable FromAsync(System.Func> functionAsync, System.Reactive.Concurrency.TaskObservationOptions options) { } public static System.IObservable FromAsync(System.Func> functionAsync, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.IObservable FromAsync(System.Func> functionAsync, System.Reactive.Concurrency.TaskObservationOptions options) { } [System.Obsolete(@"This conversion is no longer supported. Replace use of the Begin/End asynchronous method pair with a new Task-based async method, and convert the result using ToObservable. If no Task-based async method is available, use Task.Factory.FromAsync to obtain a Task object.")] public static System.Func> FromAsyncPattern(System.Func begin, System.Action end) { } [System.Obsolete(@"This conversion is no longer supported. Replace use of the Begin/End asynchronous method pair with a new Task-based async method, and convert the result using ToObservable. If no Task-based async method is available, use Task.Factory.FromAsync to obtain a Task object.")] public static System.Func> FromAsyncPattern(System.Func begin, System.Func end) { } [System.Obsolete(@"This conversion is no longer supported. Replace use of the Begin/End asynchronous method pair with a new Task-based async method, and convert the result using ToObservable. If no Task-based async method is available, use Task.Factory.FromAsync to obtain a Task object.")] public static System.Func> FromAsyncPattern(System.Func begin, System.Action end) { } [System.Obsolete(@"This conversion is no longer supported. Replace use of the Begin/End asynchronous method pair with a new Task-based async method, and convert the result using ToObservable. If no Task-based async method is available, use Task.Factory.FromAsync to obtain a Task object.")] public static System.Func> FromAsyncPattern(System.Func begin, System.Func end) { } [System.Obsolete(@"This conversion is no longer supported. Replace use of the Begin/End asynchronous method pair with a new Task-based async method, and convert the result using ToObservable. If no Task-based async method is available, use Task.Factory.FromAsync to obtain a Task object.")] public static System.Func> FromAsyncPattern(System.Func begin, System.Action end) { } [System.Obsolete(@"This conversion is no longer supported. Replace use of the Begin/End asynchronous method pair with a new Task-based async method, and convert the result using ToObservable. If no Task-based async method is available, use Task.Factory.FromAsync to obtain a Task object.")] public static System.Func> FromAsyncPattern(System.Func begin, System.Func end) { } [System.Obsolete(@"This conversion is no longer supported. Replace use of the Begin/End asynchronous method pair with a new Task-based async method, and convert the result using ToObservable. If no Task-based async method is available, use Task.Factory.FromAsync to obtain a Task object.")] public static System.Func> FromAsyncPattern(System.Func begin, System.Action end) { } [System.Obsolete(@"This conversion is no longer supported. Replace use of the Begin/End asynchronous method pair with a new Task-based async method, and convert the result using ToObservable. If no Task-based async method is available, use Task.Factory.FromAsync to obtain a Task object.")] public static System.Func> FromAsyncPattern(System.Func begin, System.Func end) { } [System.Obsolete(@"This conversion is no longer supported. Replace use of the Begin/End asynchronous method pair with a new Task-based async method, and convert the result using ToObservable. If no Task-based async method is available, use Task.Factory.FromAsync to obtain a Task object.")] public static System.Func> FromAsyncPattern(System.Func begin, System.Action end) { } [System.Obsolete(@"This conversion is no longer supported. Replace use of the Begin/End asynchronous method pair with a new Task-based async method, and convert the result using ToObservable. If no Task-based async method is available, use Task.Factory.FromAsync to obtain a Task object.")] public static System.Func> FromAsyncPattern(System.Func begin, System.Func end) { } [System.Obsolete(@"This conversion is no longer supported. Replace use of the Begin/End asynchronous method pair with a new Task-based async method, and convert the result using ToObservable. If no Task-based async method is available, use Task.Factory.FromAsync to obtain a Task object.")] public static System.Func> FromAsyncPattern(System.Func begin, System.Action end) { } [System.Obsolete(@"This conversion is no longer supported. Replace use of the Begin/End asynchronous method pair with a new Task-based async method, and convert the result using ToObservable. If no Task-based async method is available, use Task.Factory.FromAsync to obtain a Task object.")] public static System.Func> FromAsyncPattern(System.Func begin, System.Func end) { } [System.Obsolete(@"This conversion is no longer supported. Replace use of the Begin/End asynchronous method pair with a new Task-based async method, and convert the result using ToObservable. If no Task-based async method is available, use Task.Factory.FromAsync to obtain a Task object.")] public static System.Func> FromAsyncPattern(System.Func begin, System.Action end) { } [System.Obsolete(@"This conversion is no longer supported. Replace use of the Begin/End asynchronous method pair with a new Task-based async method, and convert the result using ToObservable. If no Task-based async method is available, use Task.Factory.FromAsync to obtain a Task object.")] public static System.Func> FromAsyncPattern(System.Func begin, System.Action end) { } [System.Obsolete(@"This conversion is no longer supported. Replace use of the Begin/End asynchronous method pair with a new Task-based async method, and convert the result using ToObservable. If no Task-based async method is available, use Task.Factory.FromAsync to obtain a Task object.")] public static System.Func> FromAsyncPattern(System.Func begin, System.Func end) { } [System.Obsolete(@"This conversion is no longer supported. Replace use of the Begin/End asynchronous method pair with a new Task-based async method, and convert the result using ToObservable. If no Task-based async method is available, use Task.Factory.FromAsync to obtain a Task object.")] public static System.Func> FromAsyncPattern(System.Func begin, System.Func end) { } [System.Obsolete(@"This conversion is no longer supported. Replace use of the Begin/End asynchronous method pair with a new Task-based async method, and convert the result using ToObservable. If no Task-based async method is available, use Task.Factory.FromAsync to obtain a Task object.")] public static System.Func> FromAsyncPattern(System.Func begin, System.Action end) { } [System.Obsolete(@"This conversion is no longer supported. Replace use of the Begin/End asynchronous method pair with a new Task-based async method, and convert the result using ToObservable. If no Task-based async method is available, use Task.Factory.FromAsync to obtain a Task object.")] public static System.Func> FromAsyncPattern(System.Func begin, System.Func end) { } [System.Obsolete(@"This conversion is no longer supported. Replace use of the Begin/End asynchronous method pair with a new Task-based async method, and convert the result using ToObservable. If no Task-based async method is available, use Task.Factory.FromAsync to obtain a Task object.")] public static System.Func> FromAsyncPattern(System.Func begin, System.Action end) { } [System.Obsolete(@"This conversion is no longer supported. Replace use of the Begin/End asynchronous method pair with a new Task-based async method, and convert the result using ToObservable. If no Task-based async method is available, use Task.Factory.FromAsync to obtain a Task object.")] public static System.Func> FromAsyncPattern(System.Func begin, System.Func end) { } [System.Obsolete(@"This conversion is no longer supported. Replace use of the Begin/End asynchronous method pair with a new Task-based async method, and convert the result using ToObservable. If no Task-based async method is available, use Task.Factory.FromAsync to obtain a Task object.")] public static System.Func> FromAsyncPattern(System.Func begin, System.Action end) { } [System.Obsolete(@"This conversion is no longer supported. Replace use of the Begin/End asynchronous method pair with a new Task-based async method, and convert the result using ToObservable. If no Task-based async method is available, use Task.Factory.FromAsync to obtain a Task object.")] public static System.Func> FromAsyncPattern(System.Func begin, System.Func end) { } [System.Obsolete(@"This conversion is no longer supported. Replace use of the Begin/End asynchronous method pair with a new Task-based async method, and convert the result using ToObservable. If no Task-based async method is available, use Task.Factory.FromAsync to obtain a Task object.")] public static System.Func> FromAsyncPattern(System.Func begin, System.Action end) { } [System.Obsolete(@"This conversion is no longer supported. Replace use of the Begin/End asynchronous method pair with a new Task-based async method, and convert the result using ToObservable. If no Task-based async method is available, use Task.Factory.FromAsync to obtain a Task object.")] public static System.Func> FromAsyncPattern(System.Func begin, System.Func end) { } [System.Obsolete(@"This conversion is no longer supported. Replace use of the Begin/End asynchronous method pair with a new Task-based async method, and convert the result using ToObservable. If no Task-based async method is available, use Task.Factory.FromAsync to obtain a Task object.")] public static System.Func> FromAsyncPattern(System.Func begin, System.Action end) { } [System.Obsolete(@"This conversion is no longer supported. Replace use of the Begin/End asynchronous method pair with a new Task-based async method, and convert the result using ToObservable. If no Task-based async method is available, use Task.Factory.FromAsync to obtain a Task object.")] public static System.Func> FromAsyncPattern(System.Func begin, System.Func end) { } [System.Obsolete(@"This conversion is no longer supported. Replace use of the Begin/End asynchronous method pair with a new Task-based async method, and convert the result using ToObservable. If no Task-based async method is available, use Task.Factory.FromAsync to obtain a Task object.")] public static System.Func> FromAsyncPattern(System.Func begin, System.Action end) { } [System.Obsolete(@"This conversion is no longer supported. Replace use of the Begin/End asynchronous method pair with a new Task-based async method, and convert the result using ToObservable. If no Task-based async method is available, use Task.Factory.FromAsync to obtain a Task object.")] public static System.Func> FromAsyncPattern(System.Func begin, System.Func end) { } [System.Obsolete(@"This conversion is no longer supported. Replace use of the Begin/End asynchronous method pair with a new Task-based async method, and convert the result using ToObservable. If no Task-based async method is available, use Task.Factory.FromAsync to obtain a Task object.")] public static System.Func> FromAsyncPattern(System.Func begin, System.Action end) { } [System.Obsolete(@"This conversion is no longer supported. Replace use of the Begin/End asynchronous method pair with a new Task-based async method, and convert the result using ToObservable. If no Task-based async method is available, use Task.Factory.FromAsync to obtain a Task object.")] public static System.Func> FromAsyncPattern(System.Func begin, System.Func end) { } public static System.IObservable FromEvent(System.Action addHandler, System.Action removeHandler) { } public static System.IObservable FromEvent(System.Action addHandler, System.Action removeHandler, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.IObservable FromEvent(System.Action> addHandler, System.Action> removeHandler) { } public static System.IObservable FromEvent(System.Action> addHandler, System.Action> removeHandler, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.IObservable FromEvent(System.Action addHandler, System.Action removeHandler) { } public static System.IObservable FromEvent(System.Action addHandler, System.Action removeHandler, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.IObservable FromEvent(System.Func, TDelegate> conversion, System.Action addHandler, System.Action removeHandler) { } public static System.IObservable FromEvent(System.Func, TDelegate> conversion, System.Action addHandler, System.Action removeHandler, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.IObservable> FromEventPattern(System.Action addHandler, System.Action removeHandler) { } public static System.IObservable> FromEventPattern(object target, string eventName) { } public static System.IObservable> FromEventPattern(System.Type type, string eventName) { } public static System.IObservable> FromEventPattern(System.Action addHandler, System.Action removeHandler, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.IObservable> FromEventPattern(object target, string eventName, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.IObservable> FromEventPattern(System.Type type, string eventName, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.IObservable> FromEventPattern(System.Action> addHandler, System.Action> removeHandler) { } public static System.IObservable> FromEventPattern(object target, string eventName) { } public static System.IObservable> FromEventPattern(System.Type type, string eventName) { } public static System.IObservable> FromEventPattern(System.Action> addHandler, System.Action> removeHandler, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.IObservable> FromEventPattern(object target, string eventName, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.IObservable> FromEventPattern(System.Type type, string eventName, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.IObservable> FromEventPattern(System.Action addHandler, System.Action removeHandler) { } public static System.IObservable> FromEventPattern(object target, string eventName) { } public static System.IObservable> FromEventPattern(System.Type type, string eventName) { } public static System.IObservable> FromEventPattern(System.Action addHandler, System.Action removeHandler, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.IObservable> FromEventPattern(System.Func, TDelegate> conversion, System.Action addHandler, System.Action removeHandler) { } public static System.IObservable> FromEventPattern(object target, string eventName, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.IObservable> FromEventPattern(System.Type type, string eventName, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.IObservable> FromEventPattern(System.Func, TDelegate> conversion, System.Action addHandler, System.Action removeHandler, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.IObservable> FromEventPattern(System.Action addHandler, System.Action removeHandler) { } public static System.IObservable> FromEventPattern(System.Action addHandler, System.Action removeHandler, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.IObservable Generate(TState initialState, System.Func condition, System.Func iterate, System.Func resultSelector) { } public static System.IObservable Generate(TState initialState, System.Func condition, System.Func iterate, System.Func resultSelector, System.Func timeSelector) { } public static System.IObservable Generate(TState initialState, System.Func condition, System.Func iterate, System.Func resultSelector, System.Func timeSelector) { } public static System.IObservable Generate(TState initialState, System.Func condition, System.Func iterate, System.Func resultSelector, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.IObservable Generate(TState initialState, System.Func condition, System.Func iterate, System.Func resultSelector, System.Func timeSelector, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.IObservable Generate(TState initialState, System.Func condition, System.Func iterate, System.Func resultSelector, System.Func timeSelector, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Reactive.Subjects.AsyncSubject GetAwaiter(this System.IObservable source) { } public static System.Reactive.Subjects.AsyncSubject GetAwaiter(this System.Reactive.Subjects.IConnectableObservable source) { } public static System.Collections.Generic.IEnumerator GetEnumerator(this System.IObservable source) { } public static System.IObservable> GroupBy(this System.IObservable source, System.Func keySelector) { } public static System.IObservable> GroupBy(this System.IObservable source, System.Func keySelector, System.Collections.Generic.IEqualityComparer comparer) { } public static System.IObservable> GroupBy(this System.IObservable source, System.Func keySelector, int capacity) { } public static System.IObservable> GroupBy(this System.IObservable source, System.Func keySelector, int capacity, System.Collections.Generic.IEqualityComparer comparer) { } public static System.IObservable> GroupBy(this System.IObservable source, System.Func keySelector, System.Func elementSelector) { } public static System.IObservable> GroupBy(this System.IObservable source, System.Func keySelector, System.Func elementSelector, System.Collections.Generic.IEqualityComparer comparer) { } public static System.IObservable> GroupBy(this System.IObservable source, System.Func keySelector, System.Func elementSelector, int capacity) { } public static System.IObservable> GroupBy(this System.IObservable source, System.Func keySelector, System.Func elementSelector, int capacity, System.Collections.Generic.IEqualityComparer comparer) { } public static System.IObservable> GroupByUntil(this System.IObservable source, System.Func keySelector, System.Func, System.IObservable> durationSelector) { } public static System.IObservable> GroupByUntil(this System.IObservable source, System.Func keySelector, System.Func, System.IObservable> durationSelector, System.Collections.Generic.IEqualityComparer comparer) { } public static System.IObservable> GroupByUntil(this System.IObservable source, System.Func keySelector, System.Func, System.IObservable> durationSelector, int capacity) { } public static System.IObservable> GroupByUntil(this System.IObservable source, System.Func keySelector, System.Func, System.IObservable> durationSelector, int capacity, System.Collections.Generic.IEqualityComparer comparer) { } public static System.IObservable> GroupByUntil(this System.IObservable source, System.Func keySelector, System.Func elementSelector, System.Func, System.IObservable> durationSelector) { } public static System.IObservable> GroupByUntil(this System.IObservable source, System.Func keySelector, System.Func elementSelector, System.Func, System.IObservable> durationSelector, System.Collections.Generic.IEqualityComparer comparer) { } public static System.IObservable> GroupByUntil(this System.IObservable source, System.Func keySelector, System.Func elementSelector, System.Func, System.IObservable> durationSelector, int capacity) { } public static System.IObservable> GroupByUntil(this System.IObservable source, System.Func keySelector, System.Func elementSelector, System.Func, System.IObservable> durationSelector, int capacity, System.Collections.Generic.IEqualityComparer comparer) { } public static System.IObservable GroupJoin(this System.IObservable left, System.IObservable right, System.Func> leftDurationSelector, System.Func> rightDurationSelector, System.Func, TResult> resultSelector) { } public static System.IObservable If(System.Func condition, System.IObservable thenSource) { } public static System.IObservable If(System.Func condition, System.IObservable thenSource, System.IObservable elseSource) { } public static System.IObservable If(System.Func condition, System.IObservable thenSource, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.IObservable IgnoreElements(this System.IObservable source) { } public static System.IObservable Interval(System.TimeSpan period) { } public static System.IObservable Interval(System.TimeSpan period, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.IObservable IsEmpty(this System.IObservable source) { } public static System.IObservable Join(this System.IObservable left, System.IObservable right, System.Func> leftDurationSelector, System.Func> rightDurationSelector, System.Func resultSelector) { } [System.Obsolete(@"This blocking operation is no longer supported. Instead, use the async version in combination with C# and Visual Basic async/await support. In case you need a blocking operation, use Wait or convert the resulting observable sequence to a Task object and block.")] public static TSource Last(this System.IObservable source) { } [System.Obsolete(@"This blocking operation is no longer supported. Instead, use the async version in combination with C# and Visual Basic async/await support. In case you need a blocking operation, use Wait or convert the resulting observable sequence to a Task object and block.")] public static TSource Last(this System.IObservable source, System.Func predicate) { } public static System.IObservable LastAsync(this System.IObservable source) { } public static System.IObservable LastAsync(this System.IObservable source, System.Func predicate) { } [System.Obsolete(@"This blocking operation is no longer supported. Instead, use the async version in combination with C# and Visual Basic async/await support. In case you need a blocking operation, use Wait or convert the resulting observable sequence to a Task object and block.")] [return: System.Diagnostics.CodeAnalysis.MaybeNull] public static TSource LastOrDefault(this System.IObservable source) { } [System.Obsolete(@"This blocking operation is no longer supported. Instead, use the async version in combination with C# and Visual Basic async/await support. In case you need a blocking operation, use Wait or convert the resulting observable sequence to a Task object and block.")] [return: System.Diagnostics.CodeAnalysis.MaybeNull] public static TSource LastOrDefault(this System.IObservable source, System.Func predicate) { } public static System.IObservable LastOrDefaultAsync(this System.IObservable source) { } public static System.IObservable LastOrDefaultAsync(this System.IObservable source, System.Func predicate) { } public static System.Collections.Generic.IEnumerable Latest(this System.IObservable source) { } public static System.IObservable LongCount(this System.IObservable source) { } public static System.IObservable LongCount(this System.IObservable source, System.Func predicate) { } public static System.IObservable> Materialize(this System.IObservable source) { } public static System.IObservable Max(this System.IObservable source) { } public static System.IObservable Max(this System.IObservable source) { } public static System.IObservable Max(this System.IObservable source) { } public static System.IObservable Max(this System.IObservable source) { } public static System.IObservable Max(this System.IObservable source) { } public static System.IObservable Max(this System.IObservable source) { } public static System.IObservable Max(this System.IObservable source) { } public static System.IObservable Max(this System.IObservable source) { } public static System.IObservable Max(this System.IObservable source) { } public static System.IObservable Max(this System.IObservable source) { } public static System.IObservable Max(this System.IObservable source) { } public static System.IObservable Max(this System.IObservable source, System.Collections.Generic.IComparer comparer) { } public static System.IObservable Max(this System.IObservable source, System.Func selector) { } public static System.IObservable Max(this System.IObservable source, System.Func selector) { } public static System.IObservable Max(this System.IObservable source, System.Func selector) { } public static System.IObservable Max(this System.IObservable source, System.Func selector) { } public static System.IObservable Max(this System.IObservable source, System.Func selector) { } public static System.IObservable Max(this System.IObservable source, System.Func selector) { } public static System.IObservable Max(this System.IObservable source, System.Func selector) { } public static System.IObservable Max(this System.IObservable source, System.Func selector) { } public static System.IObservable Max(this System.IObservable source, System.Func selector) { } public static System.IObservable Max(this System.IObservable source, System.Func selector) { } public static System.IObservable Max(this System.IObservable source, System.Func selector) { } public static System.IObservable Max(this System.IObservable source, System.Func selector, System.Collections.Generic.IComparer comparer) { } public static System.IObservable> MaxBy(this System.IObservable source, System.Func keySelector) { } public static System.IObservable> MaxBy(this System.IObservable source, System.Func keySelector, System.Collections.Generic.IComparer comparer) { } public static System.IObservable Merge(params System.IObservable[] sources) { } public static System.IObservable Merge(this System.Collections.Generic.IEnumerable> sources) { } public static System.IObservable Merge(this System.IObservable> sources) { } public static System.IObservable Merge(this System.IObservable> sources) { } public static System.IObservable Merge(System.Reactive.Concurrency.IScheduler scheduler, params System.IObservable[] sources) { } public static System.IObservable Merge(this System.Collections.Generic.IEnumerable> sources, int maxConcurrent) { } public static System.IObservable Merge(this System.Collections.Generic.IEnumerable> sources, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.IObservable Merge(this System.IObservable> sources, int maxConcurrent) { } public static System.IObservable Merge(this System.IObservable first, System.IObservable second) { } public static System.IObservable Merge(this System.Collections.Generic.IEnumerable> sources, int maxConcurrent, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.IObservable Merge(this System.IObservable first, System.IObservable second, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.IObservable Min(this System.IObservable source) { } public static System.IObservable Min(this System.IObservable source) { } public static System.IObservable Min(this System.IObservable source) { } public static System.IObservable Min(this System.IObservable source) { } public static System.IObservable Min(this System.IObservable source) { } public static System.IObservable Min(this System.IObservable source) { } public static System.IObservable Min(this System.IObservable source) { } public static System.IObservable Min(this System.IObservable source) { } public static System.IObservable Min(this System.IObservable source) { } public static System.IObservable Min(this System.IObservable source) { } public static System.IObservable Min(this System.IObservable source) { } public static System.IObservable Min(this System.IObservable source, System.Collections.Generic.IComparer comparer) { } public static System.IObservable Min(this System.IObservable source, System.Func selector) { } public static System.IObservable Min(this System.IObservable source, System.Func selector) { } public static System.IObservable Min(this System.IObservable source, System.Func selector) { } public static System.IObservable Min(this System.IObservable source, System.Func selector) { } public static System.IObservable Min(this System.IObservable source, System.Func selector) { } public static System.IObservable Min(this System.IObservable source, System.Func selector) { } public static System.IObservable Min(this System.IObservable source, System.Func selector) { } public static System.IObservable Min(this System.IObservable source, System.Func selector) { } public static System.IObservable Min(this System.IObservable source, System.Func selector) { } public static System.IObservable Min(this System.IObservable source, System.Func selector) { } public static System.IObservable Min(this System.IObservable source, System.Func selector) { } public static System.IObservable Min(this System.IObservable source, System.Func selector, System.Collections.Generic.IComparer comparer) { } public static System.IObservable> MinBy(this System.IObservable source, System.Func keySelector) { } public static System.IObservable> MinBy(this System.IObservable source, System.Func keySelector, System.Collections.Generic.IComparer comparer) { } public static System.Collections.Generic.IEnumerable MostRecent(this System.IObservable source, TSource initialValue) { } public static System.Reactive.Subjects.IConnectableObservable Multicast(this System.IObservable source, System.Reactive.Subjects.ISubject subject) { } public static System.IObservable Multicast(this System.IObservable source, System.Func> subjectSelector, System.Func, System.IObservable> selector) { } public static System.IObservable Never() { } public static System.IObservable Never(TResult witness) { } public static System.Collections.Generic.IEnumerable Next(this System.IObservable source) { } public static System.IObservable ObserveOn(this System.IObservable source, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.IObservable ObserveOn(this System.IObservable source, System.Threading.SynchronizationContext context) { } public static System.IObservable OfType(this System.IObservable source) { } public static System.IObservable OnErrorResumeNext(params System.IObservable[] sources) { } public static System.IObservable OnErrorResumeNext(this System.Collections.Generic.IEnumerable> sources) { } public static System.IObservable OnErrorResumeNext(this System.IObservable first, System.IObservable second) { } public static System.IObservable Prepend(this System.IObservable source, TSource value) { } public static System.IObservable Prepend(this System.IObservable source, TSource value, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Reactive.Subjects.IConnectableObservable Publish(this System.IObservable source) { } public static System.Reactive.Subjects.IConnectableObservable Publish(this System.IObservable source, TSource initialValue) { } public static System.IObservable Publish(this System.IObservable source, System.Func, System.IObservable> selector) { } public static System.IObservable Publish(this System.IObservable source, System.Func, System.IObservable> selector, TSource initialValue) { } public static System.Reactive.Subjects.IConnectableObservable PublishLast(this System.IObservable source) { } public static System.IObservable PublishLast(this System.IObservable source, System.Func, System.IObservable> selector) { } public static System.IObservable Range(int start, int count) { } public static System.IObservable Range(int start, int count, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.IObservable RefCount(this System.Reactive.Subjects.IConnectableObservable source) { } public static System.IObservable RefCount(this System.Reactive.Subjects.IConnectableObservable source, int minObservers) { } public static System.IObservable RefCount(this System.Reactive.Subjects.IConnectableObservable source, System.TimeSpan disconnectDelay) { } public static System.IObservable RefCount(this System.Reactive.Subjects.IConnectableObservable source, int minObservers, System.TimeSpan disconnectDelay) { } public static System.IObservable RefCount(this System.Reactive.Subjects.IConnectableObservable source, System.TimeSpan disconnectDelay, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.IObservable RefCount(this System.Reactive.Subjects.IConnectableObservable source, int minObservers, System.TimeSpan disconnectDelay, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.IObservable Repeat(TResult value) { } public static System.IObservable Repeat(this System.IObservable source) { } public static System.IObservable Repeat(TResult value, int repeatCount) { } public static System.IObservable Repeat(TResult value, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.IObservable Repeat(this System.IObservable source, int repeatCount) { } public static System.IObservable Repeat(TResult value, int repeatCount, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.IObservable RepeatWhen(this System.IObservable source, System.Func, System.IObservable> handler) { } public static System.Reactive.Subjects.IConnectableObservable Replay(this System.IObservable source) { } public static System.Reactive.Subjects.IConnectableObservable Replay(this System.IObservable source, int bufferSize) { } public static System.Reactive.Subjects.IConnectableObservable Replay(this System.IObservable source, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Reactive.Subjects.IConnectableObservable Replay(this System.IObservable source, System.TimeSpan window) { } public static System.Reactive.Subjects.IConnectableObservable Replay(this System.IObservable source, int bufferSize, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Reactive.Subjects.IConnectableObservable Replay(this System.IObservable source, int bufferSize, System.TimeSpan window) { } public static System.Reactive.Subjects.IConnectableObservable Replay(this System.IObservable source, System.TimeSpan window, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Reactive.Subjects.IConnectableObservable Replay(this System.IObservable source, int bufferSize, System.TimeSpan window, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.IObservable Replay(this System.IObservable source, System.Func, System.IObservable> selector) { } public static System.IObservable Replay(this System.IObservable source, System.Func, System.IObservable> selector, int bufferSize) { } public static System.IObservable Replay(this System.IObservable source, System.Func, System.IObservable> selector, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.IObservable Replay(this System.IObservable source, System.Func, System.IObservable> selector, System.TimeSpan window) { } public static System.IObservable Replay(this System.IObservable source, System.Func, System.IObservable> selector, int bufferSize, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.IObservable Replay(this System.IObservable source, System.Func, System.IObservable> selector, int bufferSize, System.TimeSpan window) { } public static System.IObservable Replay(this System.IObservable source, System.Func, System.IObservable> selector, System.TimeSpan window, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.IObservable Replay(this System.IObservable source, System.Func, System.IObservable> selector, int bufferSize, System.TimeSpan window, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.IObservable Retry(this System.IObservable source) { } public static System.IObservable Retry(this System.IObservable source, int retryCount) { } public static System.IObservable RetryWhen(this System.IObservable source, System.Func, System.IObservable> handler) { } public static System.IObservable Return(TResult value) { } public static System.IObservable Return(TResult value, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Reactive.Subjects.AsyncSubject RunAsync(this System.IObservable source, System.Threading.CancellationToken cancellationToken) { } public static System.Reactive.Subjects.AsyncSubject RunAsync(this System.Reactive.Subjects.IConnectableObservable source, System.Threading.CancellationToken cancellationToken) { } public static System.IObservable Sample(this System.IObservable source, System.TimeSpan interval) { } public static System.IObservable Sample(this System.IObservable source, System.TimeSpan interval, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.IObservable Sample(this System.IObservable source, System.IObservable sampler) { } public static System.IObservable Scan(this System.IObservable source, System.Func accumulator) { } public static System.IObservable Scan(this System.IObservable source, TAccumulate seed, System.Func accumulator) { } public static System.IObservable Select(this System.IObservable source, System.Func selector) { } public static System.IObservable Select(this System.IObservable source, System.Func selector) { } public static System.IObservable SelectMany(this System.IObservable source, System.Func> selector) { } public static System.IObservable SelectMany(this System.IObservable source, System.Func> selector) { } public static System.IObservable SelectMany(this System.IObservable source, System.Func> selector) { } public static System.IObservable SelectMany(this System.IObservable source, System.Func> selector) { } public static System.IObservable SelectMany(this System.IObservable source, System.Func> selector) { } public static System.IObservable SelectMany(this System.IObservable source, System.Func> selector) { } public static System.IObservable SelectMany(this System.IObservable source, System.Func> selector) { } public static System.IObservable SelectMany(this System.IObservable source, System.Func> selector) { } public static System.IObservable SelectMany(this System.IObservable source, System.IObservable other) { } public static System.IObservable SelectMany(this System.IObservable source, System.Func> onNext, System.Func> onError, System.Func> onCompleted) { } public static System.IObservable SelectMany(this System.IObservable source, System.Func> onNext, System.Func> onError, System.Func> onCompleted) { } public static System.IObservable SelectMany(this System.IObservable source, System.Func> collectionSelector, System.Func resultSelector) { } public static System.IObservable SelectMany(this System.IObservable source, System.Func> collectionSelector, System.Func resultSelector) { } public static System.IObservable SelectMany(this System.IObservable source, System.Func> taskSelector, System.Func resultSelector) { } public static System.IObservable SelectMany(this System.IObservable source, System.Func> collectionSelector, System.Func resultSelector) { } public static System.IObservable SelectMany(this System.IObservable source, System.Func> collectionSelector, System.Func resultSelector) { } public static System.IObservable SelectMany(this System.IObservable source, System.Func> taskSelector, System.Func resultSelector) { } public static System.IObservable SelectMany(this System.IObservable source, System.Func> taskSelector, System.Func resultSelector) { } public static System.IObservable SelectMany(this System.IObservable source, System.Func> taskSelector, System.Func resultSelector) { } public static System.IObservable SequenceEqual(this System.IObservable first, System.Collections.Generic.IEnumerable second) { } public static System.IObservable SequenceEqual(this System.IObservable first, System.IObservable second) { } public static System.IObservable SequenceEqual(this System.IObservable first, System.Collections.Generic.IEnumerable second, System.Collections.Generic.IEqualityComparer comparer) { } public static System.IObservable SequenceEqual(this System.IObservable first, System.IObservable second, System.Collections.Generic.IEqualityComparer comparer) { } [System.Obsolete(@"This blocking operation is no longer supported. Instead, use the async version in combination with C# and Visual Basic async/await support. In case you need a blocking operation, use Wait or convert the resulting observable sequence to a Task object and block.")] public static TSource Single(this System.IObservable source) { } [System.Obsolete(@"This blocking operation is no longer supported. Instead, use the async version in combination with C# and Visual Basic async/await support. In case you need a blocking operation, use Wait or convert the resulting observable sequence to a Task object and block.")] public static TSource Single(this System.IObservable source, System.Func predicate) { } public static System.IObservable SingleAsync(this System.IObservable source) { } public static System.IObservable SingleAsync(this System.IObservable source, System.Func predicate) { } [System.Obsolete(@"This blocking operation is no longer supported. Instead, use the async version in combination with C# and Visual Basic async/await support. In case you need a blocking operation, use Wait or convert the resulting observable sequence to a Task object and block.")] [return: System.Diagnostics.CodeAnalysis.MaybeNull] public static TSource SingleOrDefault(this System.IObservable source) { } [System.Obsolete(@"This blocking operation is no longer supported. Instead, use the async version in combination with C# and Visual Basic async/await support. In case you need a blocking operation, use Wait or convert the resulting observable sequence to a Task object and block.")] [return: System.Diagnostics.CodeAnalysis.MaybeNull] public static TSource SingleOrDefault(this System.IObservable source, System.Func predicate) { } public static System.IObservable SingleOrDefaultAsync(this System.IObservable source) { } public static System.IObservable SingleOrDefaultAsync(this System.IObservable source, System.Func predicate) { } public static System.IObservable Skip(this System.IObservable source, int count) { } public static System.IObservable Skip(this System.IObservable source, System.TimeSpan duration) { } public static System.IObservable Skip(this System.IObservable source, System.TimeSpan duration, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.IObservable SkipLast(this System.IObservable source, int count) { } public static System.IObservable SkipLast(this System.IObservable source, System.TimeSpan duration) { } public static System.IObservable SkipLast(this System.IObservable source, System.TimeSpan duration, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.IObservable SkipUntil(this System.IObservable source, System.DateTimeOffset startTime) { } public static System.IObservable SkipUntil(this System.IObservable source, System.DateTimeOffset startTime, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.IObservable SkipUntil(this System.IObservable source, System.IObservable other) { } public static System.IObservable SkipWhile(this System.IObservable source, System.Func predicate) { } public static System.IObservable SkipWhile(this System.IObservable source, System.Func predicate) { } public static System.IObservable Start(System.Action action) { } public static System.IObservable Start(System.Action action, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.IObservable Start(System.Func function) { } public static System.IObservable Start(System.Func function, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.IObservable StartAsync(System.Func actionAsync) { } public static System.IObservable StartAsync(System.Func actionAsync) { } public static System.IObservable StartAsync(System.Func actionAsync, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.IObservable StartAsync(System.Func actionAsync, System.Reactive.Concurrency.TaskObservationOptions options) { } public static System.IObservable StartAsync(System.Func actionAsync, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.IObservable StartAsync(System.Func actionAsync, System.Reactive.Concurrency.TaskObservationOptions options) { } public static System.IObservable StartAsync(System.Func> functionAsync) { } public static System.IObservable StartAsync(System.Func> functionAsync) { } public static System.IObservable StartAsync(System.Func> functionAsync, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.IObservable StartAsync(System.Func> functionAsync, System.Reactive.Concurrency.TaskObservationOptions options) { } public static System.IObservable StartAsync(System.Func> functionAsync, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.IObservable StartAsync(System.Func> functionAsync, System.Reactive.Concurrency.TaskObservationOptions options) { } public static System.IObservable StartWith(this System.IObservable source, System.Collections.Generic.IEnumerable values) { } public static System.IObservable StartWith(this System.IObservable source, params TSource[] values) { } public static System.IObservable StartWith(this System.IObservable source, System.Reactive.Concurrency.IScheduler scheduler, System.Collections.Generic.IEnumerable values) { } public static System.IObservable StartWith(this System.IObservable source, System.Reactive.Concurrency.IScheduler scheduler, params TSource[] values) { } public static System.IDisposable Subscribe(this System.Collections.Generic.IEnumerable source, System.IObserver observer) { } public static System.IDisposable Subscribe(this System.Collections.Generic.IEnumerable source, System.IObserver observer, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.IObservable SubscribeOn(this System.IObservable source, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.IObservable SubscribeOn(this System.IObservable source, System.Threading.SynchronizationContext context) { } public static System.IObservable Sum(this System.IObservable source) { } public static System.IObservable Sum(this System.IObservable source) { } public static System.IObservable Sum(this System.IObservable source) { } public static System.IObservable Sum(this System.IObservable source) { } public static System.IObservable Sum(this System.IObservable source) { } public static System.IObservable Sum(this System.IObservable source) { } public static System.IObservable Sum(this System.IObservable source) { } public static System.IObservable Sum(this System.IObservable source) { } public static System.IObservable Sum(this System.IObservable source) { } public static System.IObservable Sum(this System.IObservable source) { } public static System.IObservable Sum(this System.IObservable source, System.Func selector) { } public static System.IObservable Sum(this System.IObservable source, System.Func selector) { } public static System.IObservable Sum(this System.IObservable source, System.Func selector) { } public static System.IObservable Sum(this System.IObservable source, System.Func selector) { } public static System.IObservable Sum(this System.IObservable source, System.Func selector) { } public static System.IObservable Sum(this System.IObservable source, System.Func selector) { } public static System.IObservable Sum(this System.IObservable source, System.Func selector) { } public static System.IObservable Sum(this System.IObservable source, System.Func selector) { } public static System.IObservable Sum(this System.IObservable source, System.Func selector) { } public static System.IObservable Sum(this System.IObservable source, System.Func selector) { } public static System.IObservable Switch(this System.IObservable> sources) { } public static System.IObservable Switch(this System.IObservable> sources) { } public static System.IObservable Synchronize(this System.IObservable source) { } public static System.IObservable Synchronize(this System.IObservable source, object gate) { } public static System.IObservable Take(this System.IObservable source, int count) { } public static System.IObservable Take(this System.IObservable source, System.TimeSpan duration) { } public static System.IObservable Take(this System.IObservable source, int count, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.IObservable Take(this System.IObservable source, System.TimeSpan duration, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.IObservable TakeLast(this System.IObservable source, int count) { } public static System.IObservable TakeLast(this System.IObservable source, System.TimeSpan duration) { } public static System.IObservable TakeLast(this System.IObservable source, int count, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.IObservable TakeLast(this System.IObservable source, System.TimeSpan duration, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.IObservable TakeLast(this System.IObservable source, System.TimeSpan duration, System.Reactive.Concurrency.IScheduler timerScheduler, System.Reactive.Concurrency.IScheduler loopScheduler) { } public static System.IObservable> TakeLastBuffer(this System.IObservable source, int count) { } public static System.IObservable> TakeLastBuffer(this System.IObservable source, System.TimeSpan duration) { } public static System.IObservable> TakeLastBuffer(this System.IObservable source, System.TimeSpan duration, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.IObservable TakeUntil(this System.IObservable source, System.DateTimeOffset endTime) { } public static System.IObservable TakeUntil(this System.IObservable source, System.Func stopPredicate) { } public static System.IObservable TakeUntil(this System.IObservable source, System.Threading.CancellationToken cancellationToken) { } public static System.IObservable TakeUntil(this System.IObservable source, System.DateTimeOffset endTime, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.IObservable TakeUntil(this System.IObservable source, System.IObservable other) { } public static System.IObservable TakeWhile(this System.IObservable source, System.Func predicate) { } public static System.IObservable TakeWhile(this System.IObservable source, System.Func predicate) { } public static System.Reactive.Joins.Plan Then(this System.IObservable source, System.Func selector) { } public static System.IObservable Throttle(this System.IObservable source, System.TimeSpan dueTime) { } public static System.IObservable Throttle(this System.IObservable source, System.TimeSpan dueTime, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.IObservable Throttle(this System.IObservable source, System.Func> throttleDurationSelector) { } public static System.IObservable Throw(System.Exception exception) { } public static System.IObservable Throw(System.Exception exception, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.IObservable Throw(System.Exception exception, TResult witness) { } public static System.IObservable Throw(System.Exception exception, System.Reactive.Concurrency.IScheduler scheduler, TResult witness) { } public static System.IObservable> TimeInterval(this System.IObservable source) { } public static System.IObservable> TimeInterval(this System.IObservable source, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.IObservable Timeout(this System.IObservable source, System.DateTimeOffset dueTime) { } public static System.IObservable Timeout(this System.IObservable source, System.TimeSpan dueTime) { } public static System.IObservable Timeout(this System.IObservable source, System.DateTimeOffset dueTime, System.IObservable other) { } public static System.IObservable Timeout(this System.IObservable source, System.DateTimeOffset dueTime, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.IObservable Timeout(this System.IObservable source, System.TimeSpan dueTime, System.IObservable other) { } public static System.IObservable Timeout(this System.IObservable source, System.TimeSpan dueTime, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.IObservable Timeout(this System.IObservable source, System.DateTimeOffset dueTime, System.IObservable other, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.IObservable Timeout(this System.IObservable source, System.TimeSpan dueTime, System.IObservable other, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.IObservable Timeout(this System.IObservable source, System.Func> timeoutDurationSelector) { } public static System.IObservable Timeout(this System.IObservable source, System.Func> timeoutDurationSelector, System.IObservable other) { } public static System.IObservable Timeout(this System.IObservable source, System.IObservable firstTimeout, System.Func> timeoutDurationSelector) { } public static System.IObservable Timeout(this System.IObservable source, System.IObservable firstTimeout, System.Func> timeoutDurationSelector, System.IObservable other) { } public static System.IObservable Timer(System.DateTimeOffset dueTime) { } public static System.IObservable Timer(System.TimeSpan dueTime) { } public static System.IObservable Timer(System.DateTimeOffset dueTime, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.IObservable Timer(System.DateTimeOffset dueTime, System.TimeSpan period) { } public static System.IObservable Timer(System.TimeSpan dueTime, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.IObservable Timer(System.TimeSpan dueTime, System.TimeSpan period) { } public static System.IObservable Timer(System.DateTimeOffset dueTime, System.TimeSpan period, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.IObservable Timer(System.TimeSpan dueTime, System.TimeSpan period, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.IObservable> Timestamp(this System.IObservable source) { } public static System.IObservable> Timestamp(this System.IObservable source, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.IObservable ToArray(this System.IObservable source) { } public static System.Func> ToAsync(this System.Action action) { } public static System.Func> ToAsync(this System.Action action, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Func> ToAsync(this System.Action action) { } public static System.Func> ToAsync(this System.Func function) { } public static System.Func> ToAsync(this System.Action action, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Func> ToAsync(this System.Func function, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Func> ToAsync(this System.Action action) { } public static System.Func> ToAsync(this System.Func function) { } public static System.Func> ToAsync(this System.Action action, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Func> ToAsync(this System.Func function, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Func> ToAsync(this System.Action action) { } public static System.Func> ToAsync(this System.Func function) { } public static System.Func> ToAsync(this System.Action action, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Func> ToAsync(this System.Func function, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Func> ToAsync(this System.Action action) { } public static System.Func> ToAsync(this System.Func function) { } public static System.Func> ToAsync(this System.Action action, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Func> ToAsync(this System.Func function, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Func> ToAsync(this System.Action action) { } public static System.Func> ToAsync(this System.Func function) { } public static System.Func> ToAsync(this System.Action action, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Func> ToAsync(this System.Func function, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Func> ToAsync(this System.Action action) { } public static System.Func> ToAsync(this System.Func function) { } public static System.Func> ToAsync(this System.Action action, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Func> ToAsync(this System.Func function, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Func> ToAsync(this System.Action action) { } public static System.Func> ToAsync(this System.Func function) { } public static System.Func> ToAsync(this System.Action action, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Func> ToAsync(this System.Func function, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Func> ToAsync(this System.Action action) { } public static System.Func> ToAsync(this System.Func function) { } public static System.Func> ToAsync(this System.Action action, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Func> ToAsync(this System.Func function, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Func> ToAsync(this System.Action action) { } public static System.Func> ToAsync(this System.Func function) { } public static System.Func> ToAsync(this System.Action action, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Func> ToAsync(this System.Func function, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Func> ToAsync(this System.Action action) { } public static System.Func> ToAsync(this System.Func function) { } public static System.Func> ToAsync(this System.Action action, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Func> ToAsync(this System.Func function, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Func> ToAsync(this System.Action action) { } public static System.Func> ToAsync(this System.Func function) { } public static System.Func> ToAsync(this System.Action action, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Func> ToAsync(this System.Func function, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Func> ToAsync(this System.Action action) { } public static System.Func> ToAsync(this System.Func function) { } public static System.Func> ToAsync(this System.Action action, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Func> ToAsync(this System.Func function, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Func> ToAsync(this System.Action action) { } public static System.Func> ToAsync(this System.Func function) { } public static System.Func> ToAsync(this System.Action action, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Func> ToAsync(this System.Func function, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Func> ToAsync(this System.Action action) { } public static System.Func> ToAsync(this System.Func function) { } public static System.Func> ToAsync(this System.Action action, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Func> ToAsync(this System.Func function, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Func> ToAsync(this System.Action action) { } public static System.Func> ToAsync(this System.Func function) { } public static System.Func> ToAsync(this System.Action action, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Func> ToAsync(this System.Func function, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Func> ToAsync(this System.Action action) { } public static System.Func> ToAsync(this System.Func function) { } public static System.Func> ToAsync(this System.Action action, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Func> ToAsync(this System.Func function, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Func> ToAsync(this System.Func function) { } public static System.Func> ToAsync(this System.Func function, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.IObservable> ToDictionary(this System.IObservable source, System.Func keySelector) where TKey : notnull { } public static System.IObservable> ToDictionary(this System.IObservable source, System.Func keySelector, System.Collections.Generic.IEqualityComparer comparer) where TKey : notnull { } public static System.IObservable> ToDictionary(this System.IObservable source, System.Func keySelector, System.Func elementSelector) where TKey : notnull { } public static System.IObservable> ToDictionary(this System.IObservable source, System.Func keySelector, System.Func elementSelector, System.Collections.Generic.IEqualityComparer comparer) where TKey : notnull { } public static System.Collections.Generic.IEnumerable ToEnumerable(this System.IObservable source) { } public static System.Reactive.IEventSource ToEvent(this System.IObservable source) { } public static System.Reactive.IEventSource ToEvent(this System.IObservable source) { } public static System.Reactive.IEventPatternSource ToEventPattern(this System.IObservable> source) { } public static System.IObservable> ToList(this System.IObservable source) { } public static System.IObservable> ToLookup(this System.IObservable source, System.Func keySelector) { } public static System.IObservable> ToLookup(this System.IObservable source, System.Func keySelector, System.Collections.Generic.IEqualityComparer comparer) { } public static System.IObservable> ToLookup(this System.IObservable source, System.Func keySelector, System.Func elementSelector) { } public static System.IObservable> ToLookup(this System.IObservable source, System.Func keySelector, System.Func elementSelector, System.Collections.Generic.IEqualityComparer comparer) { } public static System.IObservable ToObservable(this System.Collections.Generic.IEnumerable source) { } public static System.IObservable ToObservable(this System.Collections.Generic.IEnumerable source, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.IObservable Using(System.Func resourceFactory, System.Func> observableFactory) where TResource : System.IDisposable { } public static System.IObservable Using(System.Func> resourceFactoryAsync, System.Func>> observableFactoryAsync) where TResource : System.IDisposable { } public static TSource Wait(this System.IObservable source) { } public static System.IObservable When(params System.Reactive.Joins.Plan[] plans) { } public static System.IObservable When(this System.Collections.Generic.IEnumerable> plans) { } public static System.IObservable Where(this System.IObservable source, System.Func predicate) { } public static System.IObservable Where(this System.IObservable source, System.Func predicate) { } public static System.IObservable While(System.Func condition, System.IObservable source) { } public static System.IObservable> Window(this System.IObservable source, int count) { } public static System.IObservable> Window(this System.IObservable source, System.TimeSpan timeSpan) { } public static System.IObservable> Window(this System.IObservable source, int count, int skip) { } public static System.IObservable> Window(this System.IObservable source, System.TimeSpan timeSpan, int count) { } public static System.IObservable> Window(this System.IObservable source, System.TimeSpan timeSpan, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.IObservable> Window(this System.IObservable source, System.TimeSpan timeSpan, System.TimeSpan timeShift) { } public static System.IObservable> Window(this System.IObservable source, System.TimeSpan timeSpan, int count, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.IObservable> Window(this System.IObservable source, System.TimeSpan timeSpan, System.TimeSpan timeShift, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.IObservable> Window(this System.IObservable source, System.Func> windowClosingSelector) { } public static System.IObservable> Window(this System.IObservable source, System.IObservable windowBoundaries) { } public static System.IObservable> Window(this System.IObservable source, System.IObservable windowOpenings, System.Func> windowClosingSelector) { } public static System.IObservable WithLatestFrom(this System.IObservable first, System.IObservable second, System.Func resultSelector) { } public static System.IObservable> Zip(params System.IObservable[] sources) { } public static System.IObservable> Zip(this System.Collections.Generic.IEnumerable> sources) { } public static System.IObservable Zip(this System.Collections.Generic.IEnumerable> sources, System.Func, TResult> resultSelector) { } public static System.IObservable Zip(this System.IObservable first, System.Collections.Generic.IEnumerable second, System.Func resultSelector) { } public static System.IObservable Zip(this System.IObservable first, System.IObservable second, System.Func resultSelector) { } public static System.IObservable Zip(this System.IObservable source1, System.IObservable source2, System.IObservable source3, System.Func resultSelector) { } public static System.IObservable Zip(this System.IObservable source1, System.IObservable source2, System.IObservable source3, System.IObservable source4, System.Func resultSelector) { } public static System.IObservable Zip(this System.IObservable source1, System.IObservable source2, System.IObservable source3, System.IObservable source4, System.IObservable source5, System.Func resultSelector) { } public static System.IObservable Zip(this System.IObservable source1, System.IObservable source2, System.IObservable source3, System.IObservable source4, System.IObservable source5, System.IObservable source6, System.Func resultSelector) { } public static System.IObservable Zip(this System.IObservable source1, System.IObservable source2, System.IObservable source3, System.IObservable source4, System.IObservable source5, System.IObservable source6, System.IObservable source7, System.Func resultSelector) { } public static System.IObservable Zip(this System.IObservable source1, System.IObservable source2, System.IObservable source3, System.IObservable source4, System.IObservable source5, System.IObservable source6, System.IObservable source7, System.IObservable source8, System.Func resultSelector) { } public static System.IObservable Zip(this System.IObservable source1, System.IObservable source2, System.IObservable source3, System.IObservable source4, System.IObservable source5, System.IObservable source6, System.IObservable source7, System.IObservable source8, System.IObservable source9, System.Func resultSelector) { } public static System.IObservable Zip(this System.IObservable source1, System.IObservable source2, System.IObservable source3, System.IObservable source4, System.IObservable source5, System.IObservable source6, System.IObservable source7, System.IObservable source8, System.IObservable source9, System.IObservable source10, System.Func resultSelector) { } public static System.IObservable Zip(this System.IObservable source1, System.IObservable source2, System.IObservable source3, System.IObservable source4, System.IObservable source5, System.IObservable source6, System.IObservable source7, System.IObservable source8, System.IObservable source9, System.IObservable source10, System.IObservable source11, System.Func resultSelector) { } public static System.IObservable Zip(this System.IObservable source1, System.IObservable source2, System.IObservable source3, System.IObservable source4, System.IObservable source5, System.IObservable source6, System.IObservable source7, System.IObservable source8, System.IObservable source9, System.IObservable source10, System.IObservable source11, System.IObservable source12, System.Func resultSelector) { } public static System.IObservable Zip(this System.IObservable source1, System.IObservable source2, System.IObservable source3, System.IObservable source4, System.IObservable source5, System.IObservable source6, System.IObservable source7, System.IObservable source8, System.IObservable source9, System.IObservable source10, System.IObservable source11, System.IObservable source12, System.IObservable source13, System.Func resultSelector) { } public static System.IObservable Zip(this System.IObservable source1, System.IObservable source2, System.IObservable source3, System.IObservable source4, System.IObservable source5, System.IObservable source6, System.IObservable source7, System.IObservable source8, System.IObservable source9, System.IObservable source10, System.IObservable source11, System.IObservable source12, System.IObservable source13, System.IObservable source14, System.Func resultSelector) { } public static System.IObservable Zip( this System.IObservable source1, System.IObservable source2, System.IObservable source3, System.IObservable source4, System.IObservable source5, System.IObservable source6, System.IObservable source7, System.IObservable source8, System.IObservable source9, System.IObservable source10, System.IObservable source11, System.IObservable source12, System.IObservable source13, System.IObservable source14, System.IObservable source15, System.Func resultSelector) { } public static System.IObservable Zip( this System.IObservable source1, System.IObservable source2, System.IObservable source3, System.IObservable source4, System.IObservable source5, System.IObservable source6, System.IObservable source7, System.IObservable source8, System.IObservable source9, System.IObservable source10, System.IObservable source11, System.IObservable source12, System.IObservable source13, System.IObservable source14, System.IObservable source15, System.IObservable source16, System.Func resultSelector) { } } public static class ObservableEx { [return: System.Runtime.CompilerServices.TupleElementNames(new string[] { "First", "Second"})] public static System.IObservable> CombineLatest(this System.IObservable first, System.IObservable second) { } [return: System.Runtime.CompilerServices.TupleElementNames(new string[] { "First", "Second", "Third"})] public static System.IObservable> CombineLatest(this System.IObservable first, System.IObservable second, System.IObservable third) { } [return: System.Runtime.CompilerServices.TupleElementNames(new string[] { "First", "Second", "Third", "Fourth"})] public static System.IObservable> CombineLatest(this System.IObservable first, System.IObservable second, System.IObservable third, System.IObservable fourth) { } [return: System.Runtime.CompilerServices.TupleElementNames(new string[] { "First", "Second", "Third", "Fourth", "Fifth"})] public static System.IObservable> CombineLatest(this System.IObservable first, System.IObservable second, System.IObservable third, System.IObservable fourth, System.IObservable fifth) { } [return: System.Runtime.CompilerServices.TupleElementNames(new string[] { "First", "Second", "Third", "Fourth", "Fifth", "Sixth"})] public static System.IObservable> CombineLatest(this System.IObservable first, System.IObservable second, System.IObservable third, System.IObservable fourth, System.IObservable fifth, System.IObservable sixth) { } [return: System.Runtime.CompilerServices.TupleElementNames(new string[] { "First", "Second", "Third", "Fourth", "Fifth", "Sixth", "Seventh"})] public static System.IObservable> CombineLatest(this System.IObservable first, System.IObservable second, System.IObservable third, System.IObservable fourth, System.IObservable fifth, System.IObservable sixth, System.IObservable seventh) { } [return: System.Runtime.CompilerServices.TupleElementNames(new string[] { "First", "Second", "Third", "Fourth", "Fifth", "Sixth", "Seventh", "Eighth", null})] public static System.IObservable>> CombineLatest(this System.IObservable first, System.IObservable second, System.IObservable third, System.IObservable fourth, System.IObservable fifth, System.IObservable sixth, System.IObservable seventh, System.IObservable eighth) { } [System.Reactive.Experimental] public static System.IObservable Create(System.Func>> iteratorMethod) { } [System.Reactive.Experimental] public static System.IObservable Create(System.Func, System.Collections.Generic.IEnumerable>> iteratorMethod) { } [System.Reactive.Experimental] public static System.IObservable Expand(this System.IObservable source, System.Func> selector) { } [System.Reactive.Experimental] public static System.IObservable Expand(this System.IObservable source, System.Func> selector, System.Reactive.Concurrency.IScheduler scheduler) { } [System.Reactive.Experimental] public static System.IObservable ForkJoin(params System.IObservable[] sources) { } [System.Reactive.Experimental] public static System.IObservable ForkJoin(this System.Collections.Generic.IEnumerable> sources) { } [System.Reactive.Experimental] public static System.IObservable ForkJoin(this System.IObservable first, System.IObservable second, System.Func resultSelector) { } [System.Reactive.Experimental] public static System.IObservable Let(this System.IObservable source, System.Func, System.IObservable> selector) { } [System.Reactive.Experimental] public static System.IObservable ManySelect(this System.IObservable source, System.Func, TResult> selector) { } [System.Reactive.Experimental] public static System.IObservable ManySelect(this System.IObservable source, System.Func, TResult> selector, System.Reactive.Concurrency.IScheduler scheduler) { } [System.Reactive.Experimental] public static System.Reactive.ListObservable ToListObservable(this System.IObservable source) { } [return: System.Runtime.CompilerServices.TupleElementNames(new string[] { "First", "Second"})] public static System.IObservable> WithLatestFrom(this System.IObservable first, System.IObservable second) { } [return: System.Runtime.CompilerServices.TupleElementNames(new string[] { "First", "Second"})] public static System.IObservable> Zip(this System.IObservable first, System.Collections.Generic.IEnumerable second) { } [return: System.Runtime.CompilerServices.TupleElementNames(new string[] { "First", "Second"})] public static System.IObservable> Zip(this System.IObservable first, System.IObservable second) { } [return: System.Runtime.CompilerServices.TupleElementNames(new string[] { "First", "Second", "Third"})] public static System.IObservable> Zip(this System.IObservable first, System.IObservable second, System.IObservable third) { } [return: System.Runtime.CompilerServices.TupleElementNames(new string[] { "First", "Second", "Third", "Fourth"})] public static System.IObservable> Zip(this System.IObservable first, System.IObservable second, System.IObservable third, System.IObservable fourth) { } [return: System.Runtime.CompilerServices.TupleElementNames(new string[] { "First", "Second", "Third", "Fourth", "Fifth"})] public static System.IObservable> Zip(this System.IObservable first, System.IObservable second, System.IObservable third, System.IObservable fourth, System.IObservable fifth) { } [return: System.Runtime.CompilerServices.TupleElementNames(new string[] { "First", "Second", "Third", "Fourth", "Fifth", "Sixth"})] public static System.IObservable> Zip(this System.IObservable first, System.IObservable second, System.IObservable third, System.IObservable fourth, System.IObservable fifth, System.IObservable sixth) { } [return: System.Runtime.CompilerServices.TupleElementNames(new string[] { "First", "Second", "Third", "Fourth", "Fifth", "Sixth", "Seventh"})] public static System.IObservable> Zip(this System.IObservable first, System.IObservable second, System.IObservable third, System.IObservable fourth, System.IObservable fifth, System.IObservable sixth, System.IObservable seventh) { } [return: System.Runtime.CompilerServices.TupleElementNames(new string[] { "First", "Second", "Third", "Fourth", "Fifth", "Sixth", "Seventh", "Eighth", null})] public static System.IObservable>> Zip(this System.IObservable first, System.IObservable second, System.IObservable third, System.IObservable fourth, System.IObservable fifth, System.IObservable sixth, System.IObservable seventh, System.IObservable eighth) { } } [System.Diagnostics.CodeAnalysis.ExcludeFromCodeCoverage] public static class Qbservable { public static System.Reactive.Linq.IQbservableProvider Provider { get; } public static System.Reactive.Linq.IQbservable Aggregate(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression> accumulator) { } public static System.Reactive.Linq.IQbservable Aggregate(this System.Reactive.Linq.IQbservable source, TAccumulate seed, System.Linq.Expressions.Expression> accumulator) { } public static System.Reactive.Linq.IQbservable Aggregate(this System.Reactive.Linq.IQbservable source, TAccumulate seed, System.Linq.Expressions.Expression> accumulator, System.Linq.Expressions.Expression> resultSelector) { } public static System.Reactive.Linq.IQbservable All(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression> predicate) { } public static System.Reactive.Linq.IQbservable Amb(this System.Reactive.Linq.IQbservableProvider provider, System.Collections.Generic.IEnumerable> sources) { } public static System.Reactive.Linq.IQbservable Amb(this System.Reactive.Linq.IQbservableProvider provider, params System.IObservable[] sources) { } public static System.Reactive.Linq.IQbservable Amb(this System.Reactive.Linq.IQbservable first, System.IObservable second) { } public static System.Reactive.Joins.QueryablePattern And(this System.Reactive.Linq.IQbservable left, System.IObservable right) { } public static System.Reactive.Linq.IQbservable Any(this System.Reactive.Linq.IQbservable source) { } public static System.Reactive.Linq.IQbservable Any(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression> predicate) { } public static System.Reactive.Linq.IQbservable Append(this System.Reactive.Linq.IQbservable source, TSource value) { } public static System.Reactive.Linq.IQbservable Append(this System.Reactive.Linq.IQbservable source, TSource value, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.IObservable AsObservable(this System.Reactive.Linq.IQbservable source) { } public static System.Reactive.Linq.IQbservable AsQbservable(this System.IObservable source) { } public static System.Reactive.Linq.IQbservable AutoConnect(this System.Reactive.Linq.IQbservableProvider provider, System.Reactive.Subjects.IConnectableObservable source, int minObservers, System.Linq.Expressions.Expression> onConnect) { } public static System.Reactive.Linq.IQbservable Average(this System.Reactive.Linq.IQbservable source) { } public static System.Reactive.Linq.IQbservable Average(this System.Reactive.Linq.IQbservable source) { } public static System.Reactive.Linq.IQbservable Average(this System.Reactive.Linq.IQbservable source) { } public static System.Reactive.Linq.IQbservable Average(this System.Reactive.Linq.IQbservable source) { } public static System.Reactive.Linq.IQbservable Average(this System.Reactive.Linq.IQbservable source) { } public static System.Reactive.Linq.IQbservable Average(this System.Reactive.Linq.IQbservable source) { } public static System.Reactive.Linq.IQbservable Average(this System.Reactive.Linq.IQbservable source) { } public static System.Reactive.Linq.IQbservable Average(this System.Reactive.Linq.IQbservable source) { } public static System.Reactive.Linq.IQbservable Average(this System.Reactive.Linq.IQbservable source) { } public static System.Reactive.Linq.IQbservable Average(this System.Reactive.Linq.IQbservable source) { } public static System.Reactive.Linq.IQbservable Average(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression> selector) { } public static System.Reactive.Linq.IQbservable Average(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression> selector) { } public static System.Reactive.Linq.IQbservable Average(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression> selector) { } public static System.Reactive.Linq.IQbservable Average(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression> selector) { } public static System.Reactive.Linq.IQbservable Average(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression> selector) { } public static System.Reactive.Linq.IQbservable Average(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression> selector) { } public static System.Reactive.Linq.IQbservable Average(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression> selector) { } public static System.Reactive.Linq.IQbservable Average(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression> selector) { } public static System.Reactive.Linq.IQbservable Average(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression> selector) { } public static System.Reactive.Linq.IQbservable Average(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression> selector) { } public static System.Reactive.Linq.IQbservable> Buffer(this System.Reactive.Linq.IQbservable source, int count) { } public static System.Reactive.Linq.IQbservable> Buffer(this System.Reactive.Linq.IQbservable source, System.TimeSpan timeSpan) { } public static System.Reactive.Linq.IQbservable> Buffer(this System.Reactive.Linq.IQbservable source, int count, int skip) { } public static System.Reactive.Linq.IQbservable> Buffer(this System.Reactive.Linq.IQbservable source, System.TimeSpan timeSpan, int count) { } public static System.Reactive.Linq.IQbservable> Buffer(this System.Reactive.Linq.IQbservable source, System.TimeSpan timeSpan, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Reactive.Linq.IQbservable> Buffer(this System.Reactive.Linq.IQbservable source, System.TimeSpan timeSpan, System.TimeSpan timeShift) { } public static System.Reactive.Linq.IQbservable> Buffer(this System.Reactive.Linq.IQbservable source, System.TimeSpan timeSpan, int count, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Reactive.Linq.IQbservable> Buffer(this System.Reactive.Linq.IQbservable source, System.TimeSpan timeSpan, System.TimeSpan timeShift, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Reactive.Linq.IQbservable> Buffer(this System.Reactive.Linq.IQbservable source, System.IObservable bufferBoundaries) { } public static System.Reactive.Linq.IQbservable> Buffer(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression>> bufferClosingSelector) { } public static System.Reactive.Linq.IQbservable> Buffer(this System.Reactive.Linq.IQbservable source, System.IObservable bufferOpenings, System.Linq.Expressions.Expression>> bufferClosingSelector) { } public static System.Reactive.Linq.IQbservable Case(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> selector, System.Collections.Generic.IDictionary> sources) where TValue : notnull { } public static System.Reactive.Linq.IQbservable Case(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> selector, System.Collections.Generic.IDictionary> sources, System.IObservable defaultSource) where TValue : notnull { } public static System.Reactive.Linq.IQbservable Case(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> selector, System.Collections.Generic.IDictionary> sources, System.Reactive.Concurrency.IScheduler scheduler) where TValue : notnull { } public static System.Reactive.Linq.IQbservable Cast(this System.Reactive.Linq.IQbservable source) { } public static System.Reactive.Linq.IQbservable Catch(this System.Reactive.Linq.IQbservableProvider provider, System.Collections.Generic.IEnumerable> sources) { } public static System.Reactive.Linq.IQbservable Catch(this System.Reactive.Linq.IQbservableProvider provider, params System.IObservable[] sources) { } public static System.Reactive.Linq.IQbservable Catch(this System.Reactive.Linq.IQbservable first, System.IObservable second) { } public static System.Reactive.Linq.IQbservable Catch(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression>> handler) where TException : System.Exception { } public static System.Linq.IQueryable> Chunkify(this System.Reactive.Linq.IQbservable source) { } public static System.Linq.IQueryable Collect(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression> newCollector, System.Linq.Expressions.Expression> merge) { } public static System.Linq.IQueryable Collect(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression> getInitialCollector, System.Linq.Expressions.Expression> merge, System.Linq.Expressions.Expression> getNewCollector) { } public static System.Reactive.Linq.IQbservable> CombineLatest(this System.Reactive.Linq.IQbservableProvider provider, System.Collections.Generic.IEnumerable> sources) { } public static System.Reactive.Linq.IQbservable> CombineLatest(this System.Reactive.Linq.IQbservableProvider provider, params System.IObservable[] sources) { } public static System.Reactive.Linq.IQbservable CombineLatest(this System.Reactive.Linq.IQbservableProvider provider, System.Collections.Generic.IEnumerable> sources, System.Linq.Expressions.Expression, TResult>> resultSelector) { } public static System.Reactive.Linq.IQbservable CombineLatest(this System.Reactive.Linq.IQbservable first, System.IObservable second, System.Linq.Expressions.Expression> resultSelector) { } public static System.Reactive.Linq.IQbservable CombineLatest(this System.Reactive.Linq.IQbservable source1, System.IObservable source2, System.IObservable source3, System.Linq.Expressions.Expression> resultSelector) { } public static System.Reactive.Linq.IQbservable CombineLatest(this System.Reactive.Linq.IQbservable source1, System.IObservable source2, System.IObservable source3, System.IObservable source4, System.Linq.Expressions.Expression> resultSelector) { } public static System.Reactive.Linq.IQbservable CombineLatest(this System.Reactive.Linq.IQbservable source1, System.IObservable source2, System.IObservable source3, System.IObservable source4, System.IObservable source5, System.Linq.Expressions.Expression> resultSelector) { } public static System.Reactive.Linq.IQbservable CombineLatest(this System.Reactive.Linq.IQbservable source1, System.IObservable source2, System.IObservable source3, System.IObservable source4, System.IObservable source5, System.IObservable source6, System.Linq.Expressions.Expression> resultSelector) { } public static System.Reactive.Linq.IQbservable CombineLatest(this System.Reactive.Linq.IQbservable source1, System.IObservable source2, System.IObservable source3, System.IObservable source4, System.IObservable source5, System.IObservable source6, System.IObservable source7, System.Linq.Expressions.Expression> resultSelector) { } public static System.Reactive.Linq.IQbservable CombineLatest(this System.Reactive.Linq.IQbservable source1, System.IObservable source2, System.IObservable source3, System.IObservable source4, System.IObservable source5, System.IObservable source6, System.IObservable source7, System.IObservable source8, System.Linq.Expressions.Expression> resultSelector) { } public static System.Reactive.Linq.IQbservable CombineLatest(this System.Reactive.Linq.IQbservable source1, System.IObservable source2, System.IObservable source3, System.IObservable source4, System.IObservable source5, System.IObservable source6, System.IObservable source7, System.IObservable source8, System.IObservable source9, System.Linq.Expressions.Expression> resultSelector) { } public static System.Reactive.Linq.IQbservable CombineLatest(this System.Reactive.Linq.IQbservable source1, System.IObservable source2, System.IObservable source3, System.IObservable source4, System.IObservable source5, System.IObservable source6, System.IObservable source7, System.IObservable source8, System.IObservable source9, System.IObservable source10, System.Linq.Expressions.Expression> resultSelector) { } public static System.Reactive.Linq.IQbservable CombineLatest(this System.Reactive.Linq.IQbservable source1, System.IObservable source2, System.IObservable source3, System.IObservable source4, System.IObservable source5, System.IObservable source6, System.IObservable source7, System.IObservable source8, System.IObservable source9, System.IObservable source10, System.IObservable source11, System.Linq.Expressions.Expression> resultSelector) { } public static System.Reactive.Linq.IQbservable CombineLatest(this System.Reactive.Linq.IQbservable source1, System.IObservable source2, System.IObservable source3, System.IObservable source4, System.IObservable source5, System.IObservable source6, System.IObservable source7, System.IObservable source8, System.IObservable source9, System.IObservable source10, System.IObservable source11, System.IObservable source12, System.Linq.Expressions.Expression> resultSelector) { } public static System.Reactive.Linq.IQbservable CombineLatest(this System.Reactive.Linq.IQbservable source1, System.IObservable source2, System.IObservable source3, System.IObservable source4, System.IObservable source5, System.IObservable source6, System.IObservable source7, System.IObservable source8, System.IObservable source9, System.IObservable source10, System.IObservable source11, System.IObservable source12, System.IObservable source13, System.Linq.Expressions.Expression> resultSelector) { } public static System.Reactive.Linq.IQbservable CombineLatest(this System.Reactive.Linq.IQbservable source1, System.IObservable source2, System.IObservable source3, System.IObservable source4, System.IObservable source5, System.IObservable source6, System.IObservable source7, System.IObservable source8, System.IObservable source9, System.IObservable source10, System.IObservable source11, System.IObservable source12, System.IObservable source13, System.IObservable source14, System.Linq.Expressions.Expression> resultSelector) { } public static System.Reactive.Linq.IQbservable CombineLatest( this System.Reactive.Linq.IQbservable source1, System.IObservable source2, System.IObservable source3, System.IObservable source4, System.IObservable source5, System.IObservable source6, System.IObservable source7, System.IObservable source8, System.IObservable source9, System.IObservable source10, System.IObservable source11, System.IObservable source12, System.IObservable source13, System.IObservable source14, System.IObservable source15, System.Linq.Expressions.Expression> resultSelector) { } public static System.Reactive.Linq.IQbservable CombineLatest( this System.Reactive.Linq.IQbservable source1, System.IObservable source2, System.IObservable source3, System.IObservable source4, System.IObservable source5, System.IObservable source6, System.IObservable source7, System.IObservable source8, System.IObservable source9, System.IObservable source10, System.IObservable source11, System.IObservable source12, System.IObservable source13, System.IObservable source14, System.IObservable source15, System.IObservable source16, System.Linq.Expressions.Expression> resultSelector) { } public static System.Reactive.Linq.IQbservable Concat(this System.Reactive.Linq.IQbservable> sources) { } public static System.Reactive.Linq.IQbservable Concat(this System.Reactive.Linq.IQbservable> sources) { } public static System.Reactive.Linq.IQbservable Concat(this System.Reactive.Linq.IQbservableProvider provider, System.Collections.Generic.IEnumerable> sources) { } public static System.Reactive.Linq.IQbservable Concat(this System.Reactive.Linq.IQbservableProvider provider, params System.IObservable[] sources) { } public static System.Reactive.Linq.IQbservable Concat(this System.Reactive.Linq.IQbservable first, System.IObservable second) { } public static System.Reactive.Linq.IQbservable Contains(this System.Reactive.Linq.IQbservable source, TSource value) { } public static System.Reactive.Linq.IQbservable Contains(this System.Reactive.Linq.IQbservable source, TSource value, System.Collections.Generic.IEqualityComparer comparer) { } public static System.Reactive.Linq.IQbservable Count(this System.Reactive.Linq.IQbservable source) { } public static System.Reactive.Linq.IQbservable Count(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression> predicate) { } public static System.Reactive.Linq.IQbservable Create(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression, System.Action>> subscribe) { } public static System.Reactive.Linq.IQbservable Create(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression, System.IDisposable>> subscribe) { } public static System.Reactive.Linq.IQbservable Create(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression, System.Threading.Tasks.Task>> subscribeAsync) { } public static System.Reactive.Linq.IQbservable Create(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression, System.Threading.Tasks.Task>> subscribeAsync) { } public static System.Reactive.Linq.IQbservable Create(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression, System.Threading.Tasks.Task>> subscribeAsync) { } public static System.Reactive.Linq.IQbservable Create(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression, System.Threading.CancellationToken, System.Threading.Tasks.Task>> subscribeAsync) { } public static System.Reactive.Linq.IQbservable Create(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression, System.Threading.CancellationToken, System.Threading.Tasks.Task>> subscribeAsync) { } public static System.Reactive.Linq.IQbservable Create(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression, System.Threading.CancellationToken, System.Threading.Tasks.Task>> subscribeAsync) { } public static System.Reactive.Linq.IQbservable DefaultIfEmpty(this System.Reactive.Linq.IQbservable source) { } public static System.Reactive.Linq.IQbservable DefaultIfEmpty(this System.Reactive.Linq.IQbservable source, TSource defaultValue) { } public static System.Reactive.Linq.IQbservable Defer(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression>> observableFactory) { } public static System.Reactive.Linq.IQbservable Defer(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression>>> observableFactoryAsync) { } public static System.Reactive.Linq.IQbservable Defer(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression>>> observableFactoryAsync, bool ignoreExceptionsAfterUnsubscribe) { } public static System.Reactive.Linq.IQbservable DeferAsync(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression>>> observableFactoryAsync) { } public static System.Reactive.Linq.IQbservable DeferAsync(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression>>> observableFactoryAsync, bool ignoreExceptionsAfterUnsubscribe) { } public static System.Reactive.Linq.IQbservable Delay(this System.Reactive.Linq.IQbservable source, System.DateTimeOffset dueTime) { } public static System.Reactive.Linq.IQbservable Delay(this System.Reactive.Linq.IQbservable source, System.TimeSpan dueTime) { } public static System.Reactive.Linq.IQbservable Delay(this System.Reactive.Linq.IQbservable source, System.DateTimeOffset dueTime, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Reactive.Linq.IQbservable Delay(this System.Reactive.Linq.IQbservable source, System.TimeSpan dueTime, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Reactive.Linq.IQbservable Delay(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression>> delayDurationSelector) { } public static System.Reactive.Linq.IQbservable Delay(this System.Reactive.Linq.IQbservable source, System.IObservable subscriptionDelay, System.Linq.Expressions.Expression>> delayDurationSelector) { } public static System.Reactive.Linq.IQbservable DelaySubscription(this System.Reactive.Linq.IQbservable source, System.DateTimeOffset dueTime) { } public static System.Reactive.Linq.IQbservable DelaySubscription(this System.Reactive.Linq.IQbservable source, System.TimeSpan dueTime) { } public static System.Reactive.Linq.IQbservable DelaySubscription(this System.Reactive.Linq.IQbservable source, System.DateTimeOffset dueTime, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Reactive.Linq.IQbservable DelaySubscription(this System.Reactive.Linq.IQbservable source, System.TimeSpan dueTime, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Reactive.Linq.IQbservable Dematerialize(this System.Reactive.Linq.IQbservable> source) { } public static System.Reactive.Linq.IQbservable Distinct(this System.Reactive.Linq.IQbservable source) { } public static System.Reactive.Linq.IQbservable Distinct(this System.Reactive.Linq.IQbservable source, System.Collections.Generic.IEqualityComparer comparer) { } public static System.Reactive.Linq.IQbservable Distinct(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression> keySelector) { } public static System.Reactive.Linq.IQbservable Distinct(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression> keySelector, System.Collections.Generic.IEqualityComparer comparer) { } public static System.Reactive.Linq.IQbservable DistinctUntilChanged(this System.Reactive.Linq.IQbservable source) { } public static System.Reactive.Linq.IQbservable DistinctUntilChanged(this System.Reactive.Linq.IQbservable source, System.Collections.Generic.IEqualityComparer comparer) { } public static System.Reactive.Linq.IQbservable DistinctUntilChanged(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression> keySelector) { } public static System.Reactive.Linq.IQbservable DistinctUntilChanged(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression> keySelector, System.Collections.Generic.IEqualityComparer comparer) { } public static System.Reactive.Linq.IQbservable Do(this System.Reactive.Linq.IQbservable source, System.IObserver observer) { } public static System.Reactive.Linq.IQbservable Do(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression> onNext) { } public static System.Reactive.Linq.IQbservable Do(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression> onNext, System.Linq.Expressions.Expression onCompleted) { } public static System.Reactive.Linq.IQbservable Do(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression> onNext, System.Linq.Expressions.Expression> onError) { } public static System.Reactive.Linq.IQbservable Do(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression> onNext, System.Linq.Expressions.Expression> onError, System.Linq.Expressions.Expression onCompleted) { } public static System.Reactive.Linq.IQbservable DoWhile(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression> condition) { } public static System.Reactive.Linq.IQbservable ElementAt(this System.Reactive.Linq.IQbservable source, int index) { } public static System.Reactive.Linq.IQbservable ElementAtOrDefault(this System.Reactive.Linq.IQbservable source, int index) { } public static System.Reactive.Linq.IQbservable Empty(this System.Reactive.Linq.IQbservableProvider provider) { } public static System.Reactive.Linq.IQbservable Empty(this System.Reactive.Linq.IQbservableProvider provider, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Reactive.Linq.IQbservable Empty(this System.Reactive.Linq.IQbservableProvider provider, TResult witness) { } public static System.Reactive.Linq.IQbservable Empty(this System.Reactive.Linq.IQbservableProvider provider, System.Reactive.Concurrency.IScheduler scheduler, TResult witness) { } public static System.Reactive.Linq.IQbservable Finally(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression finallyAction) { } public static System.Reactive.Linq.IQbservable FirstAsync(this System.Reactive.Linq.IQbservable source) { } public static System.Reactive.Linq.IQbservable FirstAsync(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression> predicate) { } public static System.Reactive.Linq.IQbservable FirstOrDefaultAsync(this System.Reactive.Linq.IQbservable source) { } public static System.Reactive.Linq.IQbservable FirstOrDefaultAsync(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression> predicate) { } public static System.Reactive.Linq.IQbservable For(this System.Reactive.Linq.IQbservableProvider provider, System.Collections.Generic.IEnumerable source, System.Linq.Expressions.Expression>> resultSelector) { } public static System.Reactive.Linq.IQbservable FromAsync(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> actionAsync) { } public static System.Reactive.Linq.IQbservable FromAsync(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> actionAsync) { } public static System.Reactive.Linq.IQbservable FromAsync(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> actionAsync, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Reactive.Linq.IQbservable FromAsync(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> actionAsync, System.Reactive.Concurrency.TaskObservationOptions options) { } public static System.Reactive.Linq.IQbservable FromAsync(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> actionAsync, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Reactive.Linq.IQbservable FromAsync(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> actionAsync, System.Reactive.Concurrency.TaskObservationOptions options) { } public static System.Reactive.Linq.IQbservable FromAsync(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression>> functionAsync) { } public static System.Reactive.Linq.IQbservable FromAsync(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression>> functionAsync) { } public static System.Reactive.Linq.IQbservable FromAsync(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression>> functionAsync, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Reactive.Linq.IQbservable FromAsync(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression>> functionAsync, System.Reactive.Concurrency.TaskObservationOptions options) { } public static System.Reactive.Linq.IQbservable FromAsync(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression>> functionAsync, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Reactive.Linq.IQbservable FromAsync(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression>> functionAsync, System.Reactive.Concurrency.TaskObservationOptions options) { } public static System.Func> FromAsyncPattern(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> begin, System.Linq.Expressions.Expression> end) { } public static System.Func> FromAsyncPattern(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> begin, System.Linq.Expressions.Expression> end) { } public static System.Func> FromAsyncPattern(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> begin, System.Linq.Expressions.Expression> end) { } public static System.Func> FromAsyncPattern(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> begin, System.Linq.Expressions.Expression> end) { } public static System.Func> FromAsyncPattern(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> begin, System.Linq.Expressions.Expression> end) { } public static System.Func> FromAsyncPattern(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> begin, System.Linq.Expressions.Expression> end) { } public static System.Func> FromAsyncPattern(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> begin, System.Linq.Expressions.Expression> end) { } public static System.Func> FromAsyncPattern(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> begin, System.Linq.Expressions.Expression> end) { } public static System.Func> FromAsyncPattern(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> begin, System.Linq.Expressions.Expression> end) { } public static System.Func> FromAsyncPattern(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> begin, System.Linq.Expressions.Expression> end) { } public static System.Func> FromAsyncPattern(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> begin, System.Linq.Expressions.Expression> end) { } public static System.Func> FromAsyncPattern(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> begin, System.Linq.Expressions.Expression> end) { } public static System.Func> FromAsyncPattern(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> begin, System.Linq.Expressions.Expression> end) { } public static System.Func> FromAsyncPattern(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> begin, System.Linq.Expressions.Expression> end) { } public static System.Func> FromAsyncPattern(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> begin, System.Linq.Expressions.Expression> end) { } public static System.Func> FromAsyncPattern(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> begin, System.Linq.Expressions.Expression> end) { } public static System.Func> FromAsyncPattern(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> begin, System.Linq.Expressions.Expression> end) { } public static System.Func> FromAsyncPattern(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> begin, System.Linq.Expressions.Expression> end) { } public static System.Func> FromAsyncPattern(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> begin, System.Linq.Expressions.Expression> end) { } public static System.Func> FromAsyncPattern(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> begin, System.Linq.Expressions.Expression> end) { } public static System.Func> FromAsyncPattern(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> begin, System.Linq.Expressions.Expression> end) { } public static System.Func> FromAsyncPattern(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> begin, System.Linq.Expressions.Expression> end) { } public static System.Func> FromAsyncPattern(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> begin, System.Linq.Expressions.Expression> end) { } public static System.Func> FromAsyncPattern(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> begin, System.Linq.Expressions.Expression> end) { } public static System.Func> FromAsyncPattern(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> begin, System.Linq.Expressions.Expression> end) { } public static System.Func> FromAsyncPattern(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> begin, System.Linq.Expressions.Expression> end) { } public static System.Func> FromAsyncPattern(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> begin, System.Linq.Expressions.Expression> end) { } public static System.Func> FromAsyncPattern(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> begin, System.Linq.Expressions.Expression> end) { } public static System.Func> FromAsyncPattern(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> begin, System.Linq.Expressions.Expression> end) { } public static System.Func> FromAsyncPattern(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> begin, System.Linq.Expressions.Expression> end) { } public static System.Reactive.Linq.IQbservable FromEvent(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> addHandler, System.Linq.Expressions.Expression> removeHandler) { } public static System.Reactive.Linq.IQbservable FromEvent(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> addHandler, System.Linq.Expressions.Expression> removeHandler, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Reactive.Linq.IQbservable FromEvent(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression>> addHandler, System.Linq.Expressions.Expression>> removeHandler) { } public static System.Reactive.Linq.IQbservable FromEvent(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression>> addHandler, System.Linq.Expressions.Expression>> removeHandler, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Reactive.Linq.IQbservable FromEvent(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> addHandler, System.Linq.Expressions.Expression> removeHandler) { } public static System.Reactive.Linq.IQbservable FromEvent(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> addHandler, System.Linq.Expressions.Expression> removeHandler, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Reactive.Linq.IQbservable FromEvent(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression, TDelegate>> conversion, System.Linq.Expressions.Expression> addHandler, System.Linq.Expressions.Expression> removeHandler) { } public static System.Reactive.Linq.IQbservable FromEvent(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression, TDelegate>> conversion, System.Linq.Expressions.Expression> addHandler, System.Linq.Expressions.Expression> removeHandler, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Reactive.Linq.IQbservable> FromEventPattern(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> addHandler, System.Linq.Expressions.Expression> removeHandler) { } public static System.Reactive.Linq.IQbservable> FromEventPattern(this System.Reactive.Linq.IQbservableProvider provider, object target, string eventName) { } public static System.Reactive.Linq.IQbservable> FromEventPattern(this System.Reactive.Linq.IQbservableProvider provider, System.Type type, string eventName) { } public static System.Reactive.Linq.IQbservable> FromEventPattern(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> addHandler, System.Linq.Expressions.Expression> removeHandler, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Reactive.Linq.IQbservable> FromEventPattern(this System.Reactive.Linq.IQbservableProvider provider, object target, string eventName, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Reactive.Linq.IQbservable> FromEventPattern(this System.Reactive.Linq.IQbservableProvider provider, System.Type type, string eventName, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Reactive.Linq.IQbservable> FromEventPattern(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression>> addHandler, System.Linq.Expressions.Expression>> removeHandler) { } public static System.Reactive.Linq.IQbservable> FromEventPattern(this System.Reactive.Linq.IQbservableProvider provider, object target, string eventName) { } public static System.Reactive.Linq.IQbservable> FromEventPattern(this System.Reactive.Linq.IQbservableProvider provider, System.Type type, string eventName) { } public static System.Reactive.Linq.IQbservable> FromEventPattern(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression>> addHandler, System.Linq.Expressions.Expression>> removeHandler, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Reactive.Linq.IQbservable> FromEventPattern(this System.Reactive.Linq.IQbservableProvider provider, object target, string eventName, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Reactive.Linq.IQbservable> FromEventPattern(this System.Reactive.Linq.IQbservableProvider provider, System.Type type, string eventName, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Reactive.Linq.IQbservable> FromEventPattern(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> addHandler, System.Linq.Expressions.Expression> removeHandler) { } public static System.Reactive.Linq.IQbservable> FromEventPattern(this System.Reactive.Linq.IQbservableProvider provider, object target, string eventName) { } public static System.Reactive.Linq.IQbservable> FromEventPattern(this System.Reactive.Linq.IQbservableProvider provider, System.Type type, string eventName) { } public static System.Reactive.Linq.IQbservable> FromEventPattern(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> addHandler, System.Linq.Expressions.Expression> removeHandler, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Reactive.Linq.IQbservable> FromEventPattern(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression, TDelegate>> conversion, System.Linq.Expressions.Expression> addHandler, System.Linq.Expressions.Expression> removeHandler) { } public static System.Reactive.Linq.IQbservable> FromEventPattern(this System.Reactive.Linq.IQbservableProvider provider, object target, string eventName, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Reactive.Linq.IQbservable> FromEventPattern(this System.Reactive.Linq.IQbservableProvider provider, System.Type type, string eventName, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Reactive.Linq.IQbservable> FromEventPattern(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression, TDelegate>> conversion, System.Linq.Expressions.Expression> addHandler, System.Linq.Expressions.Expression> removeHandler, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Reactive.Linq.IQbservable> FromEventPattern(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> addHandler, System.Linq.Expressions.Expression> removeHandler) { } public static System.Reactive.Linq.IQbservable> FromEventPattern(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> addHandler, System.Linq.Expressions.Expression> removeHandler, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Reactive.Linq.IQbservable Generate(this System.Reactive.Linq.IQbservableProvider provider, TState initialState, System.Linq.Expressions.Expression> condition, System.Linq.Expressions.Expression> iterate, System.Linq.Expressions.Expression> resultSelector) { } public static System.Reactive.Linq.IQbservable Generate(this System.Reactive.Linq.IQbservableProvider provider, TState initialState, System.Linq.Expressions.Expression> condition, System.Linq.Expressions.Expression> iterate, System.Linq.Expressions.Expression> resultSelector, System.Linq.Expressions.Expression> timeSelector) { } public static System.Reactive.Linq.IQbservable Generate(this System.Reactive.Linq.IQbservableProvider provider, TState initialState, System.Linq.Expressions.Expression> condition, System.Linq.Expressions.Expression> iterate, System.Linq.Expressions.Expression> resultSelector, System.Linq.Expressions.Expression> timeSelector) { } public static System.Reactive.Linq.IQbservable Generate(this System.Reactive.Linq.IQbservableProvider provider, TState initialState, System.Linq.Expressions.Expression> condition, System.Linq.Expressions.Expression> iterate, System.Linq.Expressions.Expression> resultSelector, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Reactive.Linq.IQbservable Generate(this System.Reactive.Linq.IQbservableProvider provider, TState initialState, System.Linq.Expressions.Expression> condition, System.Linq.Expressions.Expression> iterate, System.Linq.Expressions.Expression> resultSelector, System.Linq.Expressions.Expression> timeSelector, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Reactive.Linq.IQbservable Generate(this System.Reactive.Linq.IQbservableProvider provider, TState initialState, System.Linq.Expressions.Expression> condition, System.Linq.Expressions.Expression> iterate, System.Linq.Expressions.Expression> resultSelector, System.Linq.Expressions.Expression> timeSelector, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Reactive.Linq.IQbservable> GroupBy(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression> keySelector) { } public static System.Reactive.Linq.IQbservable> GroupBy(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression> keySelector, System.Collections.Generic.IEqualityComparer comparer) { } public static System.Reactive.Linq.IQbservable> GroupBy(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression> keySelector, int capacity) { } public static System.Reactive.Linq.IQbservable> GroupBy(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression> keySelector, int capacity, System.Collections.Generic.IEqualityComparer comparer) { } public static System.Reactive.Linq.IQbservable> GroupBy(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression> keySelector, System.Linq.Expressions.Expression> elementSelector) { } public static System.Reactive.Linq.IQbservable> GroupBy(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression> keySelector, System.Linq.Expressions.Expression> elementSelector, System.Collections.Generic.IEqualityComparer comparer) { } public static System.Reactive.Linq.IQbservable> GroupBy(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression> keySelector, System.Linq.Expressions.Expression> elementSelector, int capacity) { } public static System.Reactive.Linq.IQbservable> GroupBy(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression> keySelector, System.Linq.Expressions.Expression> elementSelector, int capacity, System.Collections.Generic.IEqualityComparer comparer) { } public static System.Reactive.Linq.IQbservable> GroupByUntil(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression> keySelector, System.Linq.Expressions.Expression, System.IObservable>> durationSelector) { } public static System.Reactive.Linq.IQbservable> GroupByUntil(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression> keySelector, System.Linq.Expressions.Expression, System.IObservable>> durationSelector, System.Collections.Generic.IEqualityComparer comparer) { } public static System.Reactive.Linq.IQbservable> GroupByUntil(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression> keySelector, System.Linq.Expressions.Expression, System.IObservable>> durationSelector, int capacity) { } public static System.Reactive.Linq.IQbservable> GroupByUntil(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression> keySelector, System.Linq.Expressions.Expression, System.IObservable>> durationSelector, int capacity, System.Collections.Generic.IEqualityComparer comparer) { } public static System.Reactive.Linq.IQbservable> GroupByUntil(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression> keySelector, System.Linq.Expressions.Expression> elementSelector, System.Linq.Expressions.Expression, System.IObservable>> durationSelector) { } public static System.Reactive.Linq.IQbservable> GroupByUntil(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression> keySelector, System.Linq.Expressions.Expression> elementSelector, System.Linq.Expressions.Expression, System.IObservable>> durationSelector, System.Collections.Generic.IEqualityComparer comparer) { } public static System.Reactive.Linq.IQbservable> GroupByUntil(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression> keySelector, System.Linq.Expressions.Expression> elementSelector, System.Linq.Expressions.Expression, System.IObservable>> durationSelector, int capacity) { } public static System.Reactive.Linq.IQbservable> GroupByUntil(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression> keySelector, System.Linq.Expressions.Expression> elementSelector, System.Linq.Expressions.Expression, System.IObservable>> durationSelector, int capacity, System.Collections.Generic.IEqualityComparer comparer) { } public static System.Reactive.Linq.IQbservable GroupJoin(this System.Reactive.Linq.IQbservable left, System.IObservable right, System.Linq.Expressions.Expression>> leftDurationSelector, System.Linq.Expressions.Expression>> rightDurationSelector, System.Linq.Expressions.Expression, TResult>> resultSelector) { } public static System.Reactive.Linq.IQbservable If(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> condition, System.IObservable thenSource) { } public static System.Reactive.Linq.IQbservable If(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> condition, System.IObservable thenSource, System.IObservable elseSource) { } public static System.Reactive.Linq.IQbservable If(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> condition, System.IObservable thenSource, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Reactive.Linq.IQbservable IgnoreElements(this System.Reactive.Linq.IQbservable source) { } public static System.Reactive.Linq.IQbservable Interval(this System.Reactive.Linq.IQbservableProvider provider, System.TimeSpan period) { } public static System.Reactive.Linq.IQbservable Interval(this System.Reactive.Linq.IQbservableProvider provider, System.TimeSpan period, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Reactive.Linq.IQbservable IsEmpty(this System.Reactive.Linq.IQbservable source) { } public static System.Reactive.Linq.IQbservable Join(this System.Reactive.Linq.IQbservable left, System.IObservable right, System.Linq.Expressions.Expression>> leftDurationSelector, System.Linq.Expressions.Expression>> rightDurationSelector, System.Linq.Expressions.Expression> resultSelector) { } public static System.Reactive.Linq.IQbservable LastAsync(this System.Reactive.Linq.IQbservable source) { } public static System.Reactive.Linq.IQbservable LastAsync(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression> predicate) { } public static System.Reactive.Linq.IQbservable LastOrDefaultAsync(this System.Reactive.Linq.IQbservable source) { } public static System.Reactive.Linq.IQbservable LastOrDefaultAsync(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression> predicate) { } public static System.Linq.IQueryable Latest(this System.Reactive.Linq.IQbservable source) { } public static System.Reactive.Linq.IQbservable LongCount(this System.Reactive.Linq.IQbservable source) { } public static System.Reactive.Linq.IQbservable LongCount(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression> predicate) { } public static System.Reactive.Linq.IQbservable> Materialize(this System.Reactive.Linq.IQbservable source) { } public static System.Reactive.Linq.IQbservable Max(this System.Reactive.Linq.IQbservable source) { } public static System.Reactive.Linq.IQbservable Max(this System.Reactive.Linq.IQbservable source) { } public static System.Reactive.Linq.IQbservable Max(this System.Reactive.Linq.IQbservable source) { } public static System.Reactive.Linq.IQbservable Max(this System.Reactive.Linq.IQbservable source) { } public static System.Reactive.Linq.IQbservable Max(this System.Reactive.Linq.IQbservable source) { } public static System.Reactive.Linq.IQbservable Max(this System.Reactive.Linq.IQbservable source) { } public static System.Reactive.Linq.IQbservable Max(this System.Reactive.Linq.IQbservable source) { } public static System.Reactive.Linq.IQbservable Max(this System.Reactive.Linq.IQbservable source) { } public static System.Reactive.Linq.IQbservable Max(this System.Reactive.Linq.IQbservable source) { } public static System.Reactive.Linq.IQbservable Max(this System.Reactive.Linq.IQbservable source) { } public static System.Reactive.Linq.IQbservable Max(this System.Reactive.Linq.IQbservable source) { } public static System.Reactive.Linq.IQbservable Max(this System.Reactive.Linq.IQbservable source, System.Collections.Generic.IComparer comparer) { } public static System.Reactive.Linq.IQbservable Max(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression> selector) { } public static System.Reactive.Linq.IQbservable Max(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression> selector) { } public static System.Reactive.Linq.IQbservable Max(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression> selector) { } public static System.Reactive.Linq.IQbservable Max(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression> selector) { } public static System.Reactive.Linq.IQbservable Max(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression> selector) { } public static System.Reactive.Linq.IQbservable Max(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression> selector) { } public static System.Reactive.Linq.IQbservable Max(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression> selector) { } public static System.Reactive.Linq.IQbservable Max(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression> selector) { } public static System.Reactive.Linq.IQbservable Max(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression> selector) { } public static System.Reactive.Linq.IQbservable Max(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression> selector) { } public static System.Reactive.Linq.IQbservable Max(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression> selector) { } public static System.Reactive.Linq.IQbservable Max(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression> selector, System.Collections.Generic.IComparer comparer) { } public static System.Reactive.Linq.IQbservable> MaxBy(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression> keySelector) { } public static System.Reactive.Linq.IQbservable> MaxBy(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression> keySelector, System.Collections.Generic.IComparer comparer) { } public static System.Reactive.Linq.IQbservable Merge(this System.Reactive.Linq.IQbservable> sources) { } public static System.Reactive.Linq.IQbservable Merge(this System.Reactive.Linq.IQbservable> sources) { } public static System.Reactive.Linq.IQbservable Merge(this System.Reactive.Linq.IQbservableProvider provider, System.Collections.Generic.IEnumerable> sources) { } public static System.Reactive.Linq.IQbservable Merge(this System.Reactive.Linq.IQbservableProvider provider, params System.IObservable[] sources) { } public static System.Reactive.Linq.IQbservable Merge(this System.Reactive.Linq.IQbservable> sources, int maxConcurrent) { } public static System.Reactive.Linq.IQbservable Merge(this System.Reactive.Linq.IQbservable first, System.IObservable second) { } public static System.Reactive.Linq.IQbservable Merge(this System.Reactive.Linq.IQbservableProvider provider, System.Collections.Generic.IEnumerable> sources, int maxConcurrent) { } public static System.Reactive.Linq.IQbservable Merge(this System.Reactive.Linq.IQbservableProvider provider, System.Collections.Generic.IEnumerable> sources, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Reactive.Linq.IQbservable Merge(this System.Reactive.Linq.IQbservableProvider provider, System.Reactive.Concurrency.IScheduler scheduler, params System.IObservable[] sources) { } public static System.Reactive.Linq.IQbservable Merge(this System.Reactive.Linq.IQbservable first, System.IObservable second, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Reactive.Linq.IQbservable Merge(this System.Reactive.Linq.IQbservableProvider provider, System.Collections.Generic.IEnumerable> sources, int maxConcurrent, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Reactive.Linq.IQbservable Min(this System.Reactive.Linq.IQbservable source) { } public static System.Reactive.Linq.IQbservable Min(this System.Reactive.Linq.IQbservable source) { } public static System.Reactive.Linq.IQbservable Min(this System.Reactive.Linq.IQbservable source) { } public static System.Reactive.Linq.IQbservable Min(this System.Reactive.Linq.IQbservable source) { } public static System.Reactive.Linq.IQbservable Min(this System.Reactive.Linq.IQbservable source) { } public static System.Reactive.Linq.IQbservable Min(this System.Reactive.Linq.IQbservable source) { } public static System.Reactive.Linq.IQbservable Min(this System.Reactive.Linq.IQbservable source) { } public static System.Reactive.Linq.IQbservable Min(this System.Reactive.Linq.IQbservable source) { } public static System.Reactive.Linq.IQbservable Min(this System.Reactive.Linq.IQbservable source) { } public static System.Reactive.Linq.IQbservable Min(this System.Reactive.Linq.IQbservable source) { } public static System.Reactive.Linq.IQbservable Min(this System.Reactive.Linq.IQbservable source) { } public static System.Reactive.Linq.IQbservable Min(this System.Reactive.Linq.IQbservable source, System.Collections.Generic.IComparer comparer) { } public static System.Reactive.Linq.IQbservable Min(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression> selector) { } public static System.Reactive.Linq.IQbservable Min(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression> selector) { } public static System.Reactive.Linq.IQbservable Min(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression> selector) { } public static System.Reactive.Linq.IQbservable Min(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression> selector) { } public static System.Reactive.Linq.IQbservable Min(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression> selector) { } public static System.Reactive.Linq.IQbservable Min(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression> selector) { } public static System.Reactive.Linq.IQbservable Min(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression> selector) { } public static System.Reactive.Linq.IQbservable Min(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression> selector) { } public static System.Reactive.Linq.IQbservable Min(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression> selector) { } public static System.Reactive.Linq.IQbservable Min(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression> selector) { } public static System.Reactive.Linq.IQbservable Min(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression> selector) { } public static System.Reactive.Linq.IQbservable Min(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression> selector, System.Collections.Generic.IComparer comparer) { } public static System.Reactive.Linq.IQbservable> MinBy(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression> keySelector) { } public static System.Reactive.Linq.IQbservable> MinBy(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression> keySelector, System.Collections.Generic.IComparer comparer) { } public static System.Linq.IQueryable MostRecent(this System.Reactive.Linq.IQbservable source, TSource initialValue) { } public static System.Reactive.Linq.IQbservable Multicast(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression>> subjectSelector, System.Linq.Expressions.Expression, System.IObservable>> selector) { } public static System.Reactive.Linq.IQbservable Never(this System.Reactive.Linq.IQbservableProvider provider) { } public static System.Reactive.Linq.IQbservable Never(this System.Reactive.Linq.IQbservableProvider provider, TResult witness) { } public static System.Linq.IQueryable Next(this System.Reactive.Linq.IQbservable source) { } public static System.Reactive.Linq.IQbservable ObserveOn(this System.Reactive.Linq.IQbservable source, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Reactive.Linq.IQbservable ObserveOn(this System.Reactive.Linq.IQbservable source, System.Threading.SynchronizationContext context) { } public static System.Reactive.Linq.IQbservable OfType(this System.Reactive.Linq.IQbservable source) { } public static System.Reactive.Linq.IQbservable OnErrorResumeNext(this System.Reactive.Linq.IQbservableProvider provider, System.Collections.Generic.IEnumerable> sources) { } public static System.Reactive.Linq.IQbservable OnErrorResumeNext(this System.Reactive.Linq.IQbservableProvider provider, params System.IObservable[] sources) { } public static System.Reactive.Linq.IQbservable OnErrorResumeNext(this System.Reactive.Linq.IQbservable first, System.IObservable second) { } public static System.Reactive.Linq.IQbservable Prepend(this System.Reactive.Linq.IQbservable source, TSource value) { } public static System.Reactive.Linq.IQbservable Prepend(this System.Reactive.Linq.IQbservable source, TSource value, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Reactive.Linq.IQbservable Publish(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression, System.IObservable>> selector) { } public static System.Reactive.Linq.IQbservable Publish(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression, System.IObservable>> selector, TSource initialValue) { } public static System.Reactive.Linq.IQbservable PublishLast(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression, System.IObservable>> selector) { } public static System.Reactive.Linq.IQbservable Range(this System.Reactive.Linq.IQbservableProvider provider, int start, int count) { } public static System.Reactive.Linq.IQbservable Range(this System.Reactive.Linq.IQbservableProvider provider, int start, int count, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Reactive.Linq.IQbservable RefCount(this System.Reactive.Linq.IQbservableProvider provider, System.Reactive.Subjects.IConnectableObservable source) { } public static System.Reactive.Linq.IQbservable RefCount(this System.Reactive.Linq.IQbservableProvider provider, System.Reactive.Subjects.IConnectableObservable source, int minObservers) { } public static System.Reactive.Linq.IQbservable RefCount(this System.Reactive.Linq.IQbservableProvider provider, System.Reactive.Subjects.IConnectableObservable source, System.TimeSpan disconnectDelay) { } public static System.Reactive.Linq.IQbservable RefCount(this System.Reactive.Linq.IQbservableProvider provider, System.Reactive.Subjects.IConnectableObservable source, int minObservers, System.TimeSpan disconnectDelay) { } public static System.Reactive.Linq.IQbservable RefCount(this System.Reactive.Linq.IQbservableProvider provider, System.Reactive.Subjects.IConnectableObservable source, System.TimeSpan disconnectDelay, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Reactive.Linq.IQbservable RefCount(this System.Reactive.Linq.IQbservableProvider provider, System.Reactive.Subjects.IConnectableObservable source, int minObservers, System.TimeSpan disconnectDelay, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Reactive.Linq.IQbservable Repeat(this System.Reactive.Linq.IQbservable source) { } public static System.Reactive.Linq.IQbservable Repeat(this System.Reactive.Linq.IQbservableProvider provider, TResult value) { } public static System.Reactive.Linq.IQbservable Repeat(this System.Reactive.Linq.IQbservable source, int repeatCount) { } public static System.Reactive.Linq.IQbservable Repeat(this System.Reactive.Linq.IQbservableProvider provider, TResult value, int repeatCount) { } public static System.Reactive.Linq.IQbservable Repeat(this System.Reactive.Linq.IQbservableProvider provider, TResult value, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Reactive.Linq.IQbservable Repeat(this System.Reactive.Linq.IQbservableProvider provider, TResult value, int repeatCount, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Reactive.Linq.IQbservable RepeatWhen(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression, System.IObservable>> handler) { } public static System.Reactive.Linq.IQbservable Replay(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression, System.IObservable>> selector) { } public static System.Reactive.Linq.IQbservable Replay(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression, System.IObservable>> selector, int bufferSize) { } public static System.Reactive.Linq.IQbservable Replay(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression, System.IObservable>> selector, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Reactive.Linq.IQbservable Replay(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression, System.IObservable>> selector, System.TimeSpan window) { } public static System.Reactive.Linq.IQbservable Replay(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression, System.IObservable>> selector, int bufferSize, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Reactive.Linq.IQbservable Replay(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression, System.IObservable>> selector, int bufferSize, System.TimeSpan window) { } public static System.Reactive.Linq.IQbservable Replay(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression, System.IObservable>> selector, System.TimeSpan window, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Reactive.Linq.IQbservable Replay(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression, System.IObservable>> selector, int bufferSize, System.TimeSpan window, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Reactive.Linq.IQbservable Retry(this System.Reactive.Linq.IQbservable source) { } public static System.Reactive.Linq.IQbservable Retry(this System.Reactive.Linq.IQbservable source, int retryCount) { } public static System.Reactive.Linq.IQbservable RetryWhen(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression, System.IObservable>> handler) { } public static System.Reactive.Linq.IQbservable Return(this System.Reactive.Linq.IQbservableProvider provider, TResult value) { } public static System.Reactive.Linq.IQbservable Return(this System.Reactive.Linq.IQbservableProvider provider, TResult value, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Reactive.Linq.IQbservable Sample(this System.Reactive.Linq.IQbservable source, System.TimeSpan interval) { } public static System.Reactive.Linq.IQbservable Sample(this System.Reactive.Linq.IQbservable source, System.TimeSpan interval, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Reactive.Linq.IQbservable Sample(this System.Reactive.Linq.IQbservable source, System.IObservable sampler) { } public static System.Reactive.Linq.IQbservable Scan(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression> accumulator) { } public static System.Reactive.Linq.IQbservable Scan(this System.Reactive.Linq.IQbservable source, TAccumulate seed, System.Linq.Expressions.Expression> accumulator) { } public static System.Reactive.Linq.IQbservable Select(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression> selector) { } public static System.Reactive.Linq.IQbservable Select(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression> selector) { } public static System.Reactive.Linq.IQbservable SelectMany(this System.Reactive.Linq.IQbservable source, System.IObservable other) { } public static System.Reactive.Linq.IQbservable SelectMany(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression>> selector) { } public static System.Reactive.Linq.IQbservable SelectMany(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression>> selector) { } public static System.Reactive.Linq.IQbservable SelectMany(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression>> selector) { } public static System.Reactive.Linq.IQbservable SelectMany(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression>> selector) { } public static System.Reactive.Linq.IQbservable SelectMany(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression>> selector) { } public static System.Reactive.Linq.IQbservable SelectMany(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression>> selector) { } public static System.Reactive.Linq.IQbservable SelectMany(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression>> selector) { } public static System.Reactive.Linq.IQbservable SelectMany(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression>> selector) { } public static System.Reactive.Linq.IQbservable SelectMany(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression>> onNext, System.Linq.Expressions.Expression>> onError, System.Linq.Expressions.Expression>> onCompleted) { } public static System.Reactive.Linq.IQbservable SelectMany(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression>> onNext, System.Linq.Expressions.Expression>> onError, System.Linq.Expressions.Expression>> onCompleted) { } public static System.Reactive.Linq.IQbservable SelectMany(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression>> collectionSelector, System.Linq.Expressions.Expression> resultSelector) { } public static System.Reactive.Linq.IQbservable SelectMany(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression>> collectionSelector, System.Linq.Expressions.Expression> resultSelector) { } public static System.Reactive.Linq.IQbservable SelectMany(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression>> taskSelector, System.Linq.Expressions.Expression> resultSelector) { } public static System.Reactive.Linq.IQbservable SelectMany(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression>> collectionSelector, System.Linq.Expressions.Expression> resultSelector) { } public static System.Reactive.Linq.IQbservable SelectMany(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression>> collectionSelector, System.Linq.Expressions.Expression> resultSelector) { } public static System.Reactive.Linq.IQbservable SelectMany(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression>> taskSelector, System.Linq.Expressions.Expression> resultSelector) { } public static System.Reactive.Linq.IQbservable SelectMany(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression>> taskSelector, System.Linq.Expressions.Expression> resultSelector) { } public static System.Reactive.Linq.IQbservable SelectMany(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression>> taskSelector, System.Linq.Expressions.Expression> resultSelector) { } public static System.Reactive.Linq.IQbservable SequenceEqual(this System.Reactive.Linq.IQbservable first, System.Collections.Generic.IEnumerable second) { } public static System.Reactive.Linq.IQbservable SequenceEqual(this System.Reactive.Linq.IQbservable first, System.IObservable second) { } public static System.Reactive.Linq.IQbservable SequenceEqual(this System.Reactive.Linq.IQbservable first, System.Collections.Generic.IEnumerable second, System.Collections.Generic.IEqualityComparer comparer) { } public static System.Reactive.Linq.IQbservable SequenceEqual(this System.Reactive.Linq.IQbservable first, System.IObservable second, System.Collections.Generic.IEqualityComparer comparer) { } public static System.Reactive.Linq.IQbservable SingleAsync(this System.Reactive.Linq.IQbservable source) { } public static System.Reactive.Linq.IQbservable SingleAsync(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression> predicate) { } public static System.Reactive.Linq.IQbservable SingleOrDefaultAsync(this System.Reactive.Linq.IQbservable source) { } public static System.Reactive.Linq.IQbservable SingleOrDefaultAsync(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression> predicate) { } public static System.Reactive.Linq.IQbservable Skip(this System.Reactive.Linq.IQbservable source, int count) { } public static System.Reactive.Linq.IQbservable Skip(this System.Reactive.Linq.IQbservable source, System.TimeSpan duration) { } public static System.Reactive.Linq.IQbservable Skip(this System.Reactive.Linq.IQbservable source, System.TimeSpan duration, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Reactive.Linq.IQbservable SkipLast(this System.Reactive.Linq.IQbservable source, int count) { } public static System.Reactive.Linq.IQbservable SkipLast(this System.Reactive.Linq.IQbservable source, System.TimeSpan duration) { } public static System.Reactive.Linq.IQbservable SkipLast(this System.Reactive.Linq.IQbservable source, System.TimeSpan duration, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Reactive.Linq.IQbservable SkipUntil(this System.Reactive.Linq.IQbservable source, System.DateTimeOffset startTime) { } public static System.Reactive.Linq.IQbservable SkipUntil(this System.Reactive.Linq.IQbservable source, System.DateTimeOffset startTime, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Reactive.Linq.IQbservable SkipUntil(this System.Reactive.Linq.IQbservable source, System.IObservable other) { } public static System.Reactive.Linq.IQbservable SkipWhile(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression> predicate) { } public static System.Reactive.Linq.IQbservable SkipWhile(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression> predicate) { } public static System.Reactive.Linq.IQbservable Start(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression action) { } public static System.Reactive.Linq.IQbservable Start(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression action, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Reactive.Linq.IQbservable Start(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> function) { } public static System.Reactive.Linq.IQbservable Start(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> function, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Reactive.Linq.IQbservable StartAsync(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> actionAsync) { } public static System.Reactive.Linq.IQbservable StartAsync(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> actionAsync) { } public static System.Reactive.Linq.IQbservable StartAsync(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> actionAsync, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Reactive.Linq.IQbservable StartAsync(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> actionAsync, System.Reactive.Concurrency.TaskObservationOptions options) { } public static System.Reactive.Linq.IQbservable StartAsync(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> actionAsync, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Reactive.Linq.IQbservable StartAsync(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> actionAsync, System.Reactive.Concurrency.TaskObservationOptions options) { } public static System.Reactive.Linq.IQbservable StartAsync(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression>> functionAsync) { } public static System.Reactive.Linq.IQbservable StartAsync(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression>> functionAsync) { } public static System.Reactive.Linq.IQbservable StartAsync(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression>> functionAsync, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Reactive.Linq.IQbservable StartAsync(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression>> functionAsync, System.Reactive.Concurrency.TaskObservationOptions options) { } public static System.Reactive.Linq.IQbservable StartAsync(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression>> functionAsync, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Reactive.Linq.IQbservable StartAsync(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression>> functionAsync, System.Reactive.Concurrency.TaskObservationOptions options) { } public static System.Reactive.Linq.IQbservable StartWith(this System.Reactive.Linq.IQbservable source, System.Collections.Generic.IEnumerable values) { } public static System.Reactive.Linq.IQbservable StartWith(this System.Reactive.Linq.IQbservable source, params TSource[] values) { } public static System.Reactive.Linq.IQbservable StartWith(this System.Reactive.Linq.IQbservable source, System.Reactive.Concurrency.IScheduler scheduler, System.Collections.Generic.IEnumerable values) { } public static System.Reactive.Linq.IQbservable StartWith(this System.Reactive.Linq.IQbservable source, System.Reactive.Concurrency.IScheduler scheduler, params TSource[] values) { } public static System.Reactive.Linq.IQbservable SubscribeOn(this System.Reactive.Linq.IQbservable source, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Reactive.Linq.IQbservable SubscribeOn(this System.Reactive.Linq.IQbservable source, System.Threading.SynchronizationContext context) { } public static System.Reactive.Linq.IQbservable Sum(this System.Reactive.Linq.IQbservable source) { } public static System.Reactive.Linq.IQbservable Sum(this System.Reactive.Linq.IQbservable source) { } public static System.Reactive.Linq.IQbservable Sum(this System.Reactive.Linq.IQbservable source) { } public static System.Reactive.Linq.IQbservable Sum(this System.Reactive.Linq.IQbservable source) { } public static System.Reactive.Linq.IQbservable Sum(this System.Reactive.Linq.IQbservable source) { } public static System.Reactive.Linq.IQbservable Sum(this System.Reactive.Linq.IQbservable source) { } public static System.Reactive.Linq.IQbservable Sum(this System.Reactive.Linq.IQbservable source) { } public static System.Reactive.Linq.IQbservable Sum(this System.Reactive.Linq.IQbservable source) { } public static System.Reactive.Linq.IQbservable Sum(this System.Reactive.Linq.IQbservable source) { } public static System.Reactive.Linq.IQbservable Sum(this System.Reactive.Linq.IQbservable source) { } public static System.Reactive.Linq.IQbservable Sum(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression> selector) { } public static System.Reactive.Linq.IQbservable Sum(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression> selector) { } public static System.Reactive.Linq.IQbservable Sum(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression> selector) { } public static System.Reactive.Linq.IQbservable Sum(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression> selector) { } public static System.Reactive.Linq.IQbservable Sum(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression> selector) { } public static System.Reactive.Linq.IQbservable Sum(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression> selector) { } public static System.Reactive.Linq.IQbservable Sum(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression> selector) { } public static System.Reactive.Linq.IQbservable Sum(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression> selector) { } public static System.Reactive.Linq.IQbservable Sum(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression> selector) { } public static System.Reactive.Linq.IQbservable Sum(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression> selector) { } public static System.Reactive.Linq.IQbservable Switch(this System.Reactive.Linq.IQbservable> sources) { } public static System.Reactive.Linq.IQbservable Switch(this System.Reactive.Linq.IQbservable> sources) { } public static System.Reactive.Linq.IQbservable Synchronize(this System.Reactive.Linq.IQbservable source) { } public static System.Reactive.Linq.IQbservable Synchronize(this System.Reactive.Linq.IQbservable source, object gate) { } public static System.Reactive.Linq.IQbservable Take(this System.Reactive.Linq.IQbservable source, int count) { } public static System.Reactive.Linq.IQbservable Take(this System.Reactive.Linq.IQbservable source, System.TimeSpan duration) { } public static System.Reactive.Linq.IQbservable Take(this System.Reactive.Linq.IQbservable source, int count, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Reactive.Linq.IQbservable Take(this System.Reactive.Linq.IQbservable source, System.TimeSpan duration, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Reactive.Linq.IQbservable TakeLast(this System.Reactive.Linq.IQbservable source, int count) { } public static System.Reactive.Linq.IQbservable TakeLast(this System.Reactive.Linq.IQbservable source, System.TimeSpan duration) { } public static System.Reactive.Linq.IQbservable TakeLast(this System.Reactive.Linq.IQbservable source, int count, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Reactive.Linq.IQbservable TakeLast(this System.Reactive.Linq.IQbservable source, System.TimeSpan duration, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Reactive.Linq.IQbservable TakeLast(this System.Reactive.Linq.IQbservable source, System.TimeSpan duration, System.Reactive.Concurrency.IScheduler timerScheduler, System.Reactive.Concurrency.IScheduler loopScheduler) { } public static System.Reactive.Linq.IQbservable> TakeLastBuffer(this System.Reactive.Linq.IQbservable source, int count) { } public static System.Reactive.Linq.IQbservable> TakeLastBuffer(this System.Reactive.Linq.IQbservable source, System.TimeSpan duration) { } public static System.Reactive.Linq.IQbservable> TakeLastBuffer(this System.Reactive.Linq.IQbservable source, System.TimeSpan duration, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Reactive.Linq.IQbservable TakeUntil(this System.Reactive.Linq.IQbservable source, System.DateTimeOffset endTime) { } public static System.Reactive.Linq.IQbservable TakeUntil(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression> stopPredicate) { } public static System.Reactive.Linq.IQbservable TakeUntil(this System.Reactive.Linq.IQbservable source, System.Threading.CancellationToken cancellationToken) { } public static System.Reactive.Linq.IQbservable TakeUntil(this System.Reactive.Linq.IQbservable source, System.DateTimeOffset endTime, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Reactive.Linq.IQbservable TakeUntil(this System.Reactive.Linq.IQbservable source, System.IObservable other) { } public static System.Reactive.Linq.IQbservable TakeWhile(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression> predicate) { } public static System.Reactive.Linq.IQbservable TakeWhile(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression> predicate) { } public static System.Reactive.Joins.QueryablePlan Then(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression> selector) { } public static System.Reactive.Linq.IQbservable Throttle(this System.Reactive.Linq.IQbservable source, System.TimeSpan dueTime) { } public static System.Reactive.Linq.IQbservable Throttle(this System.Reactive.Linq.IQbservable source, System.TimeSpan dueTime, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Reactive.Linq.IQbservable Throttle(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression>> throttleDurationSelector) { } public static System.Reactive.Linq.IQbservable Throw(this System.Reactive.Linq.IQbservableProvider provider, System.Exception exception) { } public static System.Reactive.Linq.IQbservable Throw(this System.Reactive.Linq.IQbservableProvider provider, System.Exception exception, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Reactive.Linq.IQbservable Throw(this System.Reactive.Linq.IQbservableProvider provider, System.Exception exception, TResult witness) { } public static System.Reactive.Linq.IQbservable Throw(this System.Reactive.Linq.IQbservableProvider provider, System.Exception exception, System.Reactive.Concurrency.IScheduler scheduler, TResult witness) { } public static System.Reactive.Linq.IQbservable> TimeInterval(this System.Reactive.Linq.IQbservable source) { } public static System.Reactive.Linq.IQbservable> TimeInterval(this System.Reactive.Linq.IQbservable source, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Reactive.Linq.IQbservable Timeout(this System.Reactive.Linq.IQbservable source, System.DateTimeOffset dueTime) { } public static System.Reactive.Linq.IQbservable Timeout(this System.Reactive.Linq.IQbservable source, System.TimeSpan dueTime) { } public static System.Reactive.Linq.IQbservable Timeout(this System.Reactive.Linq.IQbservable source, System.DateTimeOffset dueTime, System.IObservable other) { } public static System.Reactive.Linq.IQbservable Timeout(this System.Reactive.Linq.IQbservable source, System.DateTimeOffset dueTime, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Reactive.Linq.IQbservable Timeout(this System.Reactive.Linq.IQbservable source, System.TimeSpan dueTime, System.IObservable other) { } public static System.Reactive.Linq.IQbservable Timeout(this System.Reactive.Linq.IQbservable source, System.TimeSpan dueTime, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Reactive.Linq.IQbservable Timeout(this System.Reactive.Linq.IQbservable source, System.DateTimeOffset dueTime, System.IObservable other, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Reactive.Linq.IQbservable Timeout(this System.Reactive.Linq.IQbservable source, System.TimeSpan dueTime, System.IObservable other, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Reactive.Linq.IQbservable Timeout(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression>> timeoutDurationSelector) { } public static System.Reactive.Linq.IQbservable Timeout(this System.Reactive.Linq.IQbservable source, System.IObservable firstTimeout, System.Linq.Expressions.Expression>> timeoutDurationSelector) { } public static System.Reactive.Linq.IQbservable Timeout(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression>> timeoutDurationSelector, System.IObservable other) { } public static System.Reactive.Linq.IQbservable Timeout(this System.Reactive.Linq.IQbservable source, System.IObservable firstTimeout, System.Linq.Expressions.Expression>> timeoutDurationSelector, System.IObservable other) { } public static System.Reactive.Linq.IQbservable Timer(this System.Reactive.Linq.IQbservableProvider provider, System.DateTimeOffset dueTime) { } public static System.Reactive.Linq.IQbservable Timer(this System.Reactive.Linq.IQbservableProvider provider, System.TimeSpan dueTime) { } public static System.Reactive.Linq.IQbservable Timer(this System.Reactive.Linq.IQbservableProvider provider, System.DateTimeOffset dueTime, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Reactive.Linq.IQbservable Timer(this System.Reactive.Linq.IQbservableProvider provider, System.DateTimeOffset dueTime, System.TimeSpan period) { } public static System.Reactive.Linq.IQbservable Timer(this System.Reactive.Linq.IQbservableProvider provider, System.TimeSpan dueTime, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Reactive.Linq.IQbservable Timer(this System.Reactive.Linq.IQbservableProvider provider, System.TimeSpan dueTime, System.TimeSpan period) { } public static System.Reactive.Linq.IQbservable Timer(this System.Reactive.Linq.IQbservableProvider provider, System.DateTimeOffset dueTime, System.TimeSpan period, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Reactive.Linq.IQbservable Timer(this System.Reactive.Linq.IQbservableProvider provider, System.TimeSpan dueTime, System.TimeSpan period, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Reactive.Linq.IQbservable> Timestamp(this System.Reactive.Linq.IQbservable source) { } public static System.Reactive.Linq.IQbservable> Timestamp(this System.Reactive.Linq.IQbservable source, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Reactive.Linq.IQbservable ToArray(this System.Reactive.Linq.IQbservable source) { } public static System.Func> ToAsync(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression action) { } public static System.Func> ToAsync(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression action, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Func> ToAsync(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> action) { } public static System.Func> ToAsync(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> function) { } public static System.Func> ToAsync(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> action, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Func> ToAsync(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> function, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Func> ToAsync(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> action) { } public static System.Func> ToAsync(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> function) { } public static System.Func> ToAsync(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> action, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Func> ToAsync(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> function, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Func> ToAsync(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> action) { } public static System.Func> ToAsync(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> function) { } public static System.Func> ToAsync(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> action, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Func> ToAsync(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> function, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Func> ToAsync(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> action) { } public static System.Func> ToAsync(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> function) { } public static System.Func> ToAsync(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> action, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Func> ToAsync(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> function, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Func> ToAsync(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> action) { } public static System.Func> ToAsync(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> function) { } public static System.Func> ToAsync(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> action, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Func> ToAsync(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> function, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Func> ToAsync(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> action) { } public static System.Func> ToAsync(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> function) { } public static System.Func> ToAsync(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> action, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Func> ToAsync(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> function, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Func> ToAsync(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> action) { } public static System.Func> ToAsync(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> function) { } public static System.Func> ToAsync(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> action, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Func> ToAsync(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> function, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Func> ToAsync(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> action) { } public static System.Func> ToAsync(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> function) { } public static System.Func> ToAsync(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> action, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Func> ToAsync(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> function, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Func> ToAsync(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> action) { } public static System.Func> ToAsync(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> function) { } public static System.Func> ToAsync(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> action, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Func> ToAsync(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> function, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Func> ToAsync(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> action) { } public static System.Func> ToAsync(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> function) { } public static System.Func> ToAsync(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> action, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Func> ToAsync(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> function, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Func> ToAsync(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> action) { } public static System.Func> ToAsync(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> function) { } public static System.Func> ToAsync(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> action, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Func> ToAsync(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> function, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Func> ToAsync(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> action) { } public static System.Func> ToAsync(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> function) { } public static System.Func> ToAsync(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> action, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Func> ToAsync(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> function, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Func> ToAsync(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> action) { } public static System.Func> ToAsync(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> function) { } public static System.Func> ToAsync(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> action, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Func> ToAsync(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> function, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Func> ToAsync(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> action) { } public static System.Func> ToAsync(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> function) { } public static System.Func> ToAsync(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> action, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Func> ToAsync(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> function, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Func> ToAsync(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> action) { } public static System.Func> ToAsync(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> function) { } public static System.Func> ToAsync(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> action, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Func> ToAsync(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> function, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Func> ToAsync(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> action) { } public static System.Func> ToAsync(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> function) { } public static System.Func> ToAsync(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> action, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Func> ToAsync(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> function, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Func> ToAsync(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> function) { } public static System.Func> ToAsync(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> function, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Reactive.Linq.IQbservable> ToDictionary(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression> keySelector) where TKey : notnull { } public static System.Reactive.Linq.IQbservable> ToDictionary(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression> keySelector, System.Collections.Generic.IEqualityComparer comparer) where TKey : notnull { } public static System.Reactive.Linq.IQbservable> ToDictionary(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression> keySelector, System.Linq.Expressions.Expression> elementSelector) where TKey : notnull { } public static System.Reactive.Linq.IQbservable> ToDictionary(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression> keySelector, System.Linq.Expressions.Expression> elementSelector, System.Collections.Generic.IEqualityComparer comparer) where TKey : notnull { } public static System.Reactive.Linq.IQbservable> ToList(this System.Reactive.Linq.IQbservable source) { } public static System.Reactive.Linq.IQbservable> ToLookup(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression> keySelector) { } public static System.Reactive.Linq.IQbservable> ToLookup(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression> keySelector, System.Collections.Generic.IEqualityComparer comparer) { } public static System.Reactive.Linq.IQbservable> ToLookup(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression> keySelector, System.Linq.Expressions.Expression> elementSelector) { } public static System.Reactive.Linq.IQbservable> ToLookup(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression> keySelector, System.Linq.Expressions.Expression> elementSelector, System.Collections.Generic.IEqualityComparer comparer) { } public static System.Reactive.Linq.IQbservable ToObservable(this System.Reactive.Linq.IQbservableProvider provider, System.Collections.Generic.IEnumerable source) { } public static System.Reactive.Linq.IQbservable ToObservable(this System.Reactive.Linq.IQbservableProvider provider, System.Collections.Generic.IEnumerable source, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Reactive.Linq.IQbservable ToQbservable(this System.Linq.IQueryable source) { } public static System.Reactive.Linq.IQbservable ToQbservable(this System.Linq.IQueryable source, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Linq.IQueryable ToQueryable(this System.Reactive.Linq.IQbservable source) { } public static System.Reactive.Linq.IQbservable Using(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> resourceFactory, System.Linq.Expressions.Expression>> observableFactory) where TResource : System.IDisposable { } public static System.Reactive.Linq.IQbservable Using(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression>> resourceFactoryAsync, System.Linq.Expressions.Expression>>> observableFactoryAsync) where TResource : System.IDisposable { } public static System.Reactive.Linq.IQbservable When(this System.Reactive.Linq.IQbservableProvider provider, System.Collections.Generic.IEnumerable> plans) { } public static System.Reactive.Linq.IQbservable When(this System.Reactive.Linq.IQbservableProvider provider, params System.Reactive.Joins.QueryablePlan[] plans) { } public static System.Reactive.Linq.IQbservable Where(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression> predicate) { } public static System.Reactive.Linq.IQbservable Where(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression> predicate) { } public static System.Reactive.Linq.IQbservable While(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression> condition, System.IObservable source) { } public static System.Reactive.Linq.IQbservable> Window(this System.Reactive.Linq.IQbservable source, int count) { } public static System.Reactive.Linq.IQbservable> Window(this System.Reactive.Linq.IQbservable source, System.TimeSpan timeSpan) { } public static System.Reactive.Linq.IQbservable> Window(this System.Reactive.Linq.IQbservable source, int count, int skip) { } public static System.Reactive.Linq.IQbservable> Window(this System.Reactive.Linq.IQbservable source, System.TimeSpan timeSpan, int count) { } public static System.Reactive.Linq.IQbservable> Window(this System.Reactive.Linq.IQbservable source, System.TimeSpan timeSpan, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Reactive.Linq.IQbservable> Window(this System.Reactive.Linq.IQbservable source, System.TimeSpan timeSpan, System.TimeSpan timeShift) { } public static System.Reactive.Linq.IQbservable> Window(this System.Reactive.Linq.IQbservable source, System.TimeSpan timeSpan, int count, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Reactive.Linq.IQbservable> Window(this System.Reactive.Linq.IQbservable source, System.TimeSpan timeSpan, System.TimeSpan timeShift, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Reactive.Linq.IQbservable> Window(this System.Reactive.Linq.IQbservable source, System.IObservable windowBoundaries) { } public static System.Reactive.Linq.IQbservable> Window(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression>> windowClosingSelector) { } public static System.Reactive.Linq.IQbservable> Window(this System.Reactive.Linq.IQbservable source, System.IObservable windowOpenings, System.Linq.Expressions.Expression>> windowClosingSelector) { } public static System.Reactive.Linq.IQbservable WithLatestFrom(this System.Reactive.Linq.IQbservable first, System.IObservable second, System.Linq.Expressions.Expression> resultSelector) { } public static System.Reactive.Linq.IQbservable> Zip(this System.Reactive.Linq.IQbservableProvider provider, System.Collections.Generic.IEnumerable> sources) { } public static System.Reactive.Linq.IQbservable> Zip(this System.Reactive.Linq.IQbservableProvider provider, params System.IObservable[] sources) { } public static System.Reactive.Linq.IQbservable Zip(this System.Reactive.Linq.IQbservableProvider provider, System.Collections.Generic.IEnumerable> sources, System.Linq.Expressions.Expression, TResult>> resultSelector) { } public static System.Reactive.Linq.IQbservable Zip(this System.Reactive.Linq.IQbservable first, System.Collections.Generic.IEnumerable second, System.Linq.Expressions.Expression> resultSelector) { } public static System.Reactive.Linq.IQbservable Zip(this System.Reactive.Linq.IQbservable first, System.IObservable second, System.Linq.Expressions.Expression> resultSelector) { } public static System.Reactive.Linq.IQbservable Zip(this System.Reactive.Linq.IQbservable source1, System.IObservable source2, System.IObservable source3, System.Linq.Expressions.Expression> resultSelector) { } public static System.Reactive.Linq.IQbservable Zip(this System.Reactive.Linq.IQbservable source1, System.IObservable source2, System.IObservable source3, System.IObservable source4, System.Linq.Expressions.Expression> resultSelector) { } public static System.Reactive.Linq.IQbservable Zip(this System.Reactive.Linq.IQbservable source1, System.IObservable source2, System.IObservable source3, System.IObservable source4, System.IObservable source5, System.Linq.Expressions.Expression> resultSelector) { } public static System.Reactive.Linq.IQbservable Zip(this System.Reactive.Linq.IQbservable source1, System.IObservable source2, System.IObservable source3, System.IObservable source4, System.IObservable source5, System.IObservable source6, System.Linq.Expressions.Expression> resultSelector) { } public static System.Reactive.Linq.IQbservable Zip(this System.Reactive.Linq.IQbservable source1, System.IObservable source2, System.IObservable source3, System.IObservable source4, System.IObservable source5, System.IObservable source6, System.IObservable source7, System.Linq.Expressions.Expression> resultSelector) { } public static System.Reactive.Linq.IQbservable Zip(this System.Reactive.Linq.IQbservable source1, System.IObservable source2, System.IObservable source3, System.IObservable source4, System.IObservable source5, System.IObservable source6, System.IObservable source7, System.IObservable source8, System.Linq.Expressions.Expression> resultSelector) { } public static System.Reactive.Linq.IQbservable Zip(this System.Reactive.Linq.IQbservable source1, System.IObservable source2, System.IObservable source3, System.IObservable source4, System.IObservable source5, System.IObservable source6, System.IObservable source7, System.IObservable source8, System.IObservable source9, System.Linq.Expressions.Expression> resultSelector) { } public static System.Reactive.Linq.IQbservable Zip(this System.Reactive.Linq.IQbservable source1, System.IObservable source2, System.IObservable source3, System.IObservable source4, System.IObservable source5, System.IObservable source6, System.IObservable source7, System.IObservable source8, System.IObservable source9, System.IObservable source10, System.Linq.Expressions.Expression> resultSelector) { } public static System.Reactive.Linq.IQbservable Zip(this System.Reactive.Linq.IQbservable source1, System.IObservable source2, System.IObservable source3, System.IObservable source4, System.IObservable source5, System.IObservable source6, System.IObservable source7, System.IObservable source8, System.IObservable source9, System.IObservable source10, System.IObservable source11, System.Linq.Expressions.Expression> resultSelector) { } public static System.Reactive.Linq.IQbservable Zip(this System.Reactive.Linq.IQbservable source1, System.IObservable source2, System.IObservable source3, System.IObservable source4, System.IObservable source5, System.IObservable source6, System.IObservable source7, System.IObservable source8, System.IObservable source9, System.IObservable source10, System.IObservable source11, System.IObservable source12, System.Linq.Expressions.Expression> resultSelector) { } public static System.Reactive.Linq.IQbservable Zip(this System.Reactive.Linq.IQbservable source1, System.IObservable source2, System.IObservable source3, System.IObservable source4, System.IObservable source5, System.IObservable source6, System.IObservable source7, System.IObservable source8, System.IObservable source9, System.IObservable source10, System.IObservable source11, System.IObservable source12, System.IObservable source13, System.Linq.Expressions.Expression> resultSelector) { } public static System.Reactive.Linq.IQbservable Zip(this System.Reactive.Linq.IQbservable source1, System.IObservable source2, System.IObservable source3, System.IObservable source4, System.IObservable source5, System.IObservable source6, System.IObservable source7, System.IObservable source8, System.IObservable source9, System.IObservable source10, System.IObservable source11, System.IObservable source12, System.IObservable source13, System.IObservable source14, System.Linq.Expressions.Expression> resultSelector) { } public static System.Reactive.Linq.IQbservable Zip( this System.Reactive.Linq.IQbservable source1, System.IObservable source2, System.IObservable source3, System.IObservable source4, System.IObservable source5, System.IObservable source6, System.IObservable source7, System.IObservable source8, System.IObservable source9, System.IObservable source10, System.IObservable source11, System.IObservable source12, System.IObservable source13, System.IObservable source14, System.IObservable source15, System.Linq.Expressions.Expression> resultSelector) { } public static System.Reactive.Linq.IQbservable Zip( this System.Reactive.Linq.IQbservable source1, System.IObservable source2, System.IObservable source3, System.IObservable source4, System.IObservable source5, System.IObservable source6, System.IObservable source7, System.IObservable source8, System.IObservable source9, System.IObservable source10, System.IObservable source11, System.IObservable source12, System.IObservable source13, System.IObservable source14, System.IObservable source15, System.IObservable source16, System.Linq.Expressions.Expression> resultSelector) { } } [System.Reactive.Linq.LocalQueryMethodImplementationType(typeof(System.Reactive.Linq.ObservableEx))] public static class QbservableEx { [return: System.Runtime.CompilerServices.TupleElementNames(new string[] { "First", "Second"})] public static System.Reactive.Linq.IQbservable> CombineLatest(this System.Reactive.Linq.IQbservable first, System.IObservable second) { } [return: System.Runtime.CompilerServices.TupleElementNames(new string[] { "First", "Second", "Third"})] public static System.Reactive.Linq.IQbservable> CombineLatest(this System.Reactive.Linq.IQbservable first, System.IObservable second, System.IObservable third) { } [return: System.Runtime.CompilerServices.TupleElementNames(new string[] { "First", "Second", "Third", "Fourth"})] public static System.Reactive.Linq.IQbservable> CombineLatest(this System.Reactive.Linq.IQbservable first, System.IObservable second, System.IObservable third, System.IObservable fourth) { } [return: System.Runtime.CompilerServices.TupleElementNames(new string[] { "First", "Second", "Third", "Fourth", "Fifth"})] public static System.Reactive.Linq.IQbservable> CombineLatest(this System.Reactive.Linq.IQbservable first, System.IObservable second, System.IObservable third, System.IObservable fourth, System.IObservable fifth) { } [return: System.Runtime.CompilerServices.TupleElementNames(new string[] { "First", "Second", "Third", "Fourth", "Fifth", "Sixth"})] public static System.Reactive.Linq.IQbservable> CombineLatest(this System.Reactive.Linq.IQbservable first, System.IObservable second, System.IObservable third, System.IObservable fourth, System.IObservable fifth, System.IObservable sixth) { } [return: System.Runtime.CompilerServices.TupleElementNames(new string[] { "First", "Second", "Third", "Fourth", "Fifth", "Sixth", "Seventh"})] public static System.Reactive.Linq.IQbservable> CombineLatest(this System.Reactive.Linq.IQbservable first, System.IObservable second, System.IObservable third, System.IObservable fourth, System.IObservable fifth, System.IObservable sixth, System.IObservable seventh) { } [return: System.Runtime.CompilerServices.TupleElementNames(new string[] { "First", "Second", "Third", "Fourth", "Fifth", "Sixth", "Seventh", "Eighth", null})] public static System.Reactive.Linq.IQbservable>> CombineLatest(this System.Reactive.Linq.IQbservable first, System.IObservable second, System.IObservable third, System.IObservable fourth, System.IObservable fifth, System.IObservable sixth, System.IObservable seventh, System.IObservable eighth) { } [return: System.Runtime.CompilerServices.TupleElementNames(new string[] { "First", "Second", "Third", "Fourth", "Fifth", "Sixth", "Seventh", "Eighth", "Ninth", null, null})] public static System.Reactive.Linq.IQbservable>> CombineLatest(this System.Reactive.Linq.IQbservable first, System.IObservable second, System.IObservable third, System.IObservable fourth, System.IObservable fifth, System.IObservable sixth, System.IObservable seventh, System.IObservable eighth, System.IObservable ninth) { } [return: System.Runtime.CompilerServices.TupleElementNames(new string[] { "First", "Second", "Third", "Fourth", "Fifth", "Sixth", "Seventh", "Eighth", "Ninth", "Tenth", null, null, null})] public static System.Reactive.Linq.IQbservable>> CombineLatest(this System.Reactive.Linq.IQbservable first, System.IObservable second, System.IObservable third, System.IObservable fourth, System.IObservable fifth, System.IObservable sixth, System.IObservable seventh, System.IObservable eighth, System.IObservable ninth, System.IObservable tenth) { } [return: System.Runtime.CompilerServices.TupleElementNames(new string[] { "First", "Second", "Third", "Fourth", "Fifth", "Sixth", "Seventh", "Eighth", "Ninth", "Tenth", "Eleventh", null, null, null, null})] public static System.Reactive.Linq.IQbservable>> CombineLatest(this System.Reactive.Linq.IQbservable first, System.IObservable second, System.IObservable third, System.IObservable fourth, System.IObservable fifth, System.IObservable sixth, System.IObservable seventh, System.IObservable eighth, System.IObservable ninth, System.IObservable tenth, System.IObservable eleventh) { } [return: System.Runtime.CompilerServices.TupleElementNames(new string[] { "First", "Second", "Third", "Fourth", "Fifth", "Sixth", "Seventh", "Eighth", "Ninth", "Tenth", "Eleventh", "Twelfth", null, null, null, null, null})] public static System.Reactive.Linq.IQbservable>> CombineLatest(this System.Reactive.Linq.IQbservable first, System.IObservable second, System.IObservable third, System.IObservable fourth, System.IObservable fifth, System.IObservable sixth, System.IObservable seventh, System.IObservable eighth, System.IObservable ninth, System.IObservable tenth, System.IObservable eleventh, System.IObservable twelfth) { } [return: System.Runtime.CompilerServices.TupleElementNames(new string[] { "First", "Second", "Third", "Fourth", "Fifth", "Sixth", "Seventh", "Eighth", "Ninth", "Tenth", "Eleventh", "Twelfth", "Thirteenth", null, null, null, null, null, null})] public static System.Reactive.Linq.IQbservable>> CombineLatest(this System.Reactive.Linq.IQbservable first, System.IObservable second, System.IObservable third, System.IObservable fourth, System.IObservable fifth, System.IObservable sixth, System.IObservable seventh, System.IObservable eighth, System.IObservable ninth, System.IObservable tenth, System.IObservable eleventh, System.IObservable twelfth, System.IObservable thirteenth) { } [return: System.Runtime.CompilerServices.TupleElementNames(new string[] { "First", "Second", "Third", "Fourth", "Fifth", "Sixth", "Seventh", "Eighth", "Ninth", "Tenth", "Eleventh", "Twelfth", "Thirteenth", "Fourteenth", null, null, null, null, null, null, null})] public static System.Reactive.Linq.IQbservable>> CombineLatest(this System.Reactive.Linq.IQbservable first, System.IObservable second, System.IObservable third, System.IObservable fourth, System.IObservable fifth, System.IObservable sixth, System.IObservable seventh, System.IObservable eighth, System.IObservable ninth, System.IObservable tenth, System.IObservable eleventh, System.IObservable twelfth, System.IObservable thirteenth, System.IObservable fourteenth) { } [return: System.Runtime.CompilerServices.TupleElementNames(new string[] { "First", "Second", "Third", "Fourth", "Fifth", "Sixth", "Seventh", "Eighth", "Ninth", "Tenth", "Eleventh", "Twelfth", "Thirteenth", "Fourteenth", "Fifteenth", null, null, null, null, null, null, null, null, null})] public static System.Reactive.Linq.IQbservable>>> CombineLatest(this System.Reactive.Linq.IQbservable first, System.IObservable second, System.IObservable third, System.IObservable fourth, System.IObservable fifth, System.IObservable sixth, System.IObservable seventh, System.IObservable eighth, System.IObservable ninth, System.IObservable tenth, System.IObservable eleventh, System.IObservable twelfth, System.IObservable thirteenth, System.IObservable fourteenth, System.IObservable fifteenth) { } [return: System.Runtime.CompilerServices.TupleElementNames(new string[] { "First", "Second", "Third", "Fourth", "Fifth", "Sixth", "Seventh", "Eighth", "Ninth", "Tenth", "Eleventh", "Twelfth", "Thirteenth", "Fourteenth", "Fifteenth", "Sixteenth", null, null, null, null, null, null, null, null, null, null, null})] public static System.Reactive.Linq.IQbservable>>> CombineLatest( this System.Reactive.Linq.IQbservable first, System.IObservable second, System.IObservable third, System.IObservable fourth, System.IObservable fifth, System.IObservable sixth, System.IObservable seventh, System.IObservable eighth, System.IObservable ninth, System.IObservable tenth, System.IObservable eleventh, System.IObservable twelfth, System.IObservable thirteenth, System.IObservable fourteenth, System.IObservable fifteenth, System.IObservable sixteenth) { } [System.Reactive.Experimental] public static System.Reactive.Linq.IQbservable Create(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression>>> iteratorMethod) { } [System.Reactive.Experimental] public static System.Reactive.Linq.IQbservable Create(this System.Reactive.Linq.IQbservableProvider provider, System.Linq.Expressions.Expression, System.Collections.Generic.IEnumerable>>> iteratorMethod) { } [System.Reactive.Experimental] public static System.Reactive.Linq.IQbservable Expand(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression>> selector) { } [System.Reactive.Experimental] public static System.Reactive.Linq.IQbservable Expand(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression>> selector, System.Reactive.Concurrency.IScheduler scheduler) { } [System.Reactive.Experimental] public static System.Reactive.Linq.IQbservable ForkJoin(this System.Reactive.Linq.IQbservableProvider provider, System.Collections.Generic.IEnumerable> sources) { } [System.Reactive.Experimental] public static System.Reactive.Linq.IQbservable ForkJoin(this System.Reactive.Linq.IQbservableProvider provider, params System.IObservable[] sources) { } [System.Reactive.Experimental] public static System.Reactive.Linq.IQbservable ForkJoin(this System.Reactive.Linq.IQbservable first, System.IObservable second, System.Linq.Expressions.Expression> resultSelector) { } [System.Reactive.Experimental] public static System.Reactive.Linq.IQbservable Let(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression, System.IObservable>> selector) { } [System.Reactive.Experimental] public static System.Reactive.Linq.IQbservable ManySelect(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression, TResult>> selector) { } [System.Reactive.Experimental] public static System.Reactive.Linq.IQbservable ManySelect(this System.Reactive.Linq.IQbservable source, System.Linq.Expressions.Expression, TResult>> selector, System.Reactive.Concurrency.IScheduler scheduler) { } [return: System.Runtime.CompilerServices.TupleElementNames(new string[] { "First", "Second"})] public static System.Reactive.Linq.IQbservable> WithLatestFrom(this System.Reactive.Linq.IQbservable first, System.IObservable second) { } [return: System.Runtime.CompilerServices.TupleElementNames(new string[] { "First", "Second"})] public static System.Reactive.Linq.IQbservable> Zip(this System.Reactive.Linq.IQbservable first, System.Collections.Generic.IEnumerable second) { } [return: System.Runtime.CompilerServices.TupleElementNames(new string[] { "First", "Second"})] public static System.Reactive.Linq.IQbservable> Zip(this System.Reactive.Linq.IQbservable first, System.IObservable second) { } [return: System.Runtime.CompilerServices.TupleElementNames(new string[] { "First", "Second", "Third"})] public static System.Reactive.Linq.IQbservable> Zip(this System.Reactive.Linq.IQbservable first, System.IObservable second, System.IObservable third) { } [return: System.Runtime.CompilerServices.TupleElementNames(new string[] { "First", "Second", "Third", "Fourth"})] public static System.Reactive.Linq.IQbservable> Zip(this System.Reactive.Linq.IQbservable first, System.IObservable second, System.IObservable third, System.IObservable fourth) { } [return: System.Runtime.CompilerServices.TupleElementNames(new string[] { "First", "Second", "Third", "Fourth", "Fifth"})] public static System.Reactive.Linq.IQbservable> Zip(this System.Reactive.Linq.IQbservable first, System.IObservable second, System.IObservable third, System.IObservable fourth, System.IObservable fifth) { } [return: System.Runtime.CompilerServices.TupleElementNames(new string[] { "First", "Second", "Third", "Fourth", "Fifth", "Sixth"})] public static System.Reactive.Linq.IQbservable> Zip(this System.Reactive.Linq.IQbservable first, System.IObservable second, System.IObservable third, System.IObservable fourth, System.IObservable fifth, System.IObservable sixth) { } [return: System.Runtime.CompilerServices.TupleElementNames(new string[] { "First", "Second", "Third", "Fourth", "Fifth", "Sixth", "Seventh"})] public static System.Reactive.Linq.IQbservable> Zip(this System.Reactive.Linq.IQbservable first, System.IObservable second, System.IObservable third, System.IObservable fourth, System.IObservable fifth, System.IObservable sixth, System.IObservable seventh) { } [return: System.Runtime.CompilerServices.TupleElementNames(new string[] { "First", "Second", "Third", "Fourth", "Fifth", "Sixth", "Seventh", "Eighth", null})] public static System.Reactive.Linq.IQbservable>> Zip(this System.Reactive.Linq.IQbservable first, System.IObservable second, System.IObservable third, System.IObservable fourth, System.IObservable fifth, System.IObservable sixth, System.IObservable seventh, System.IObservable eighth) { } [return: System.Runtime.CompilerServices.TupleElementNames(new string[] { "First", "Second", "Third", "Fourth", "Fifth", "Sixth", "Seventh", "Eighth", "Ninth", null, null})] public static System.Reactive.Linq.IQbservable>> Zip(this System.Reactive.Linq.IQbservable first, System.IObservable second, System.IObservable third, System.IObservable fourth, System.IObservable fifth, System.IObservable sixth, System.IObservable seventh, System.IObservable eighth, System.IObservable ninth) { } [return: System.Runtime.CompilerServices.TupleElementNames(new string[] { "First", "Second", "Third", "Fourth", "Fifth", "Sixth", "Seventh", "Eighth", "Ninth", "Tenth", null, null, null})] public static System.Reactive.Linq.IQbservable>> Zip(this System.Reactive.Linq.IQbservable first, System.IObservable second, System.IObservable third, System.IObservable fourth, System.IObservable fifth, System.IObservable sixth, System.IObservable seventh, System.IObservable eighth, System.IObservable ninth, System.IObservable tenth) { } [return: System.Runtime.CompilerServices.TupleElementNames(new string[] { "First", "Second", "Third", "Fourth", "Fifth", "Sixth", "Seventh", "Eighth", "Ninth", "Tenth", "Eleventh", null, null, null, null})] public static System.Reactive.Linq.IQbservable>> Zip(this System.Reactive.Linq.IQbservable first, System.IObservable second, System.IObservable third, System.IObservable fourth, System.IObservable fifth, System.IObservable sixth, System.IObservable seventh, System.IObservable eighth, System.IObservable ninth, System.IObservable tenth, System.IObservable eleventh) { } [return: System.Runtime.CompilerServices.TupleElementNames(new string[] { "First", "Second", "Third", "Fourth", "Fifth", "Sixth", "Seventh", "Eighth", "Ninth", "Tenth", "Eleventh", "Twelfth", null, null, null, null, null})] public static System.Reactive.Linq.IQbservable>> Zip(this System.Reactive.Linq.IQbservable first, System.IObservable second, System.IObservable third, System.IObservable fourth, System.IObservable fifth, System.IObservable sixth, System.IObservable seventh, System.IObservable eighth, System.IObservable ninth, System.IObservable tenth, System.IObservable eleventh, System.IObservable twelfth) { } [return: System.Runtime.CompilerServices.TupleElementNames(new string[] { "First", "Second", "Third", "Fourth", "Fifth", "Sixth", "Seventh", "Eighth", "Ninth", "Tenth", "Eleventh", "Twelfth", "Thirteenth", null, null, null, null, null, null})] public static System.Reactive.Linq.IQbservable>> Zip(this System.Reactive.Linq.IQbservable first, System.IObservable second, System.IObservable third, System.IObservable fourth, System.IObservable fifth, System.IObservable sixth, System.IObservable seventh, System.IObservable eighth, System.IObservable ninth, System.IObservable tenth, System.IObservable eleventh, System.IObservable twelfth, System.IObservable thirteenth) { } [return: System.Runtime.CompilerServices.TupleElementNames(new string[] { "First", "Second", "Third", "Fourth", "Fifth", "Sixth", "Seventh", "Eighth", "Ninth", "Tenth", "Eleventh", "Twelfth", "Thirteenth", "Fourteenth", null, null, null, null, null, null, null})] public static System.Reactive.Linq.IQbservable>> Zip(this System.Reactive.Linq.IQbservable first, System.IObservable second, System.IObservable third, System.IObservable fourth, System.IObservable fifth, System.IObservable sixth, System.IObservable seventh, System.IObservable eighth, System.IObservable ninth, System.IObservable tenth, System.IObservable eleventh, System.IObservable twelfth, System.IObservable thirteenth, System.IObservable fourteenth) { } [return: System.Runtime.CompilerServices.TupleElementNames(new string[] { "First", "Second", "Third", "Fourth", "Fifth", "Sixth", "Seventh", "Eighth", "Ninth", "Tenth", "Eleventh", "Twelfth", "Thirteenth", "Fourteenth", "Fifteenth", null, null, null, null, null, null, null, null, null})] public static System.Reactive.Linq.IQbservable>>> Zip(this System.Reactive.Linq.IQbservable first, System.IObservable second, System.IObservable third, System.IObservable fourth, System.IObservable fifth, System.IObservable sixth, System.IObservable seventh, System.IObservable eighth, System.IObservable ninth, System.IObservable tenth, System.IObservable eleventh, System.IObservable twelfth, System.IObservable thirteenth, System.IObservable fourteenth, System.IObservable fifteenth) { } [return: System.Runtime.CompilerServices.TupleElementNames(new string[] { "First", "Second", "Third", "Fourth", "Fifth", "Sixth", "Seventh", "Eighth", "Ninth", "Tenth", "Eleventh", "Twelfth", "Thirteenth", "Fourteenth", "Fifteenth", "Sixteenth", null, null, null, null, null, null, null, null, null, null, null})] public static System.Reactive.Linq.IQbservable>>> Zip( this System.Reactive.Linq.IQbservable first, System.IObservable second, System.IObservable third, System.IObservable fourth, System.IObservable fifth, System.IObservable sixth, System.IObservable seventh, System.IObservable eighth, System.IObservable ninth, System.IObservable tenth, System.IObservable eleventh, System.IObservable twelfth, System.IObservable thirteenth, System.IObservable fourteenth, System.IObservable fifteenth, System.IObservable sixteenth) { } } public class QueryDebugger { public QueryDebugger() { } } public static class RemotingObservable { public static System.IObservable Remotable(this System.IObservable source) { } public static System.Reactive.Linq.IQbservable Remotable(this System.Reactive.Linq.IQbservable source) { } public static System.IObservable Remotable(this System.IObservable source, System.Runtime.Remoting.Lifetime.ILease lease) { } public static System.Reactive.Linq.IQbservable Remotable(this System.Reactive.Linq.IQbservable source, System.Runtime.Remoting.Lifetime.ILease lease) { } } } namespace System.Reactive.PlatformServices { public class CurrentPlatformEnlightenmentProvider : System.Reactive.PlatformServices.IPlatformEnlightenmentProvider { public CurrentPlatformEnlightenmentProvider() { } public virtual T? GetService(object[] args) where T : class { } } public class DefaultSystemClock : System.Reactive.PlatformServices.ISystemClock { public DefaultSystemClock() { } public System.DateTimeOffset UtcNow { get; } } public static class EnlightenmentProvider { public static bool EnsureLoaded() { } } public static class HostLifecycleService { public static event System.EventHandler? Resuming; public static event System.EventHandler? Suspending; public static void AddRef() { } public static void Release() { } } public class HostResumingEventArgs : System.EventArgs { public HostResumingEventArgs() { } } public class HostSuspendingEventArgs : System.EventArgs { public HostSuspendingEventArgs() { } } public interface IExceptionServices { [System.Diagnostics.CodeAnalysis.DoesNotReturn] void Rethrow(System.Exception exception); } public interface IHostLifecycleNotifications { event System.EventHandler Resuming; event System.EventHandler Suspending; } public interface INotifySystemClockChanged { event System.EventHandler SystemClockChanged; } public interface IPlatformEnlightenmentProvider { T? GetService(params object[] args) where T : class; } public interface ISystemClock { System.DateTimeOffset UtcNow { get; } } public class PeriodicTimerSystemClockMonitor : System.Reactive.PlatformServices.INotifySystemClockChanged { public PeriodicTimerSystemClockMonitor(System.TimeSpan period) { } public event System.EventHandler SystemClockChanged; } public static class PlatformEnlightenmentProvider { public static System.Reactive.PlatformServices.IPlatformEnlightenmentProvider Current { get; set; } } public static class SystemClock { public static System.DateTimeOffset UtcNow { get; } public static void AddRef() { } public static void Release() { } } public class SystemClockChangedEventArgs : System.EventArgs { public SystemClockChangedEventArgs() { } public SystemClockChangedEventArgs(System.DateTimeOffset oldTime, System.DateTimeOffset newTime) { } public System.DateTimeOffset NewTime { get; } public System.DateTimeOffset OldTime { get; } } } namespace System.Reactive.Subjects { public sealed class AsyncSubject : System.Reactive.Subjects.SubjectBase, System.Runtime.CompilerServices.INotifyCompletion { public AsyncSubject() { } public override bool HasObservers { get; } public bool IsCompleted { get; } public override bool IsDisposed { get; } public override void Dispose() { } public System.Reactive.Subjects.AsyncSubject GetAwaiter() { } public T GetResult() { } public override void OnCompleted() { } public void OnCompleted(System.Action continuation) { } public override void OnError(System.Exception error) { } public override void OnNext(T value) { } public override System.IDisposable Subscribe(System.IObserver observer) { } } public sealed class BehaviorSubject : System.Reactive.Subjects.SubjectBase { public BehaviorSubject(T value) { } public override bool HasObservers { get; } public override bool IsDisposed { get; } public T Value { get; } public override void Dispose() { } public override void OnCompleted() { } public override void OnError(System.Exception error) { } public override void OnNext(T value) { } public override System.IDisposable Subscribe(System.IObserver observer) { } public bool TryGetValue([System.Diagnostics.CodeAnalysis.MaybeNullWhen(false)] out T value) { } } public interface IConnectableObservable : System.IObservable { System.IDisposable Connect(); } public interface ISubject : System.IObservable, System.IObserver, System.Reactive.Subjects.ISubject { } public interface ISubject : System.IObservable, System.IObserver { } public sealed class ReplaySubject : System.Reactive.Subjects.SubjectBase { public ReplaySubject() { } public ReplaySubject(int bufferSize) { } public ReplaySubject(System.Reactive.Concurrency.IScheduler scheduler) { } public ReplaySubject(System.TimeSpan window) { } public ReplaySubject(int bufferSize, System.Reactive.Concurrency.IScheduler scheduler) { } public ReplaySubject(int bufferSize, System.TimeSpan window) { } public ReplaySubject(System.TimeSpan window, System.Reactive.Concurrency.IScheduler scheduler) { } public ReplaySubject(int bufferSize, System.TimeSpan window, System.Reactive.Concurrency.IScheduler scheduler) { } public override bool HasObservers { get; } public override bool IsDisposed { get; } public override void Dispose() { } public override void OnCompleted() { } public override void OnError(System.Exception error) { } public override void OnNext(T value) { } public override System.IDisposable Subscribe(System.IObserver observer) { } } public static class Subject { public static System.Reactive.Subjects.ISubject Create(System.IObserver observer, System.IObservable observable) { } public static System.Reactive.Subjects.ISubject Create(System.IObserver observer, System.IObservable observable) { } public static System.Reactive.Subjects.ISubject Synchronize(System.Reactive.Subjects.ISubject subject) { } public static System.Reactive.Subjects.ISubject Synchronize(System.Reactive.Subjects.ISubject subject, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Reactive.Subjects.ISubject Synchronize(System.Reactive.Subjects.ISubject subject) { } public static System.Reactive.Subjects.ISubject Synchronize(System.Reactive.Subjects.ISubject subject, System.Reactive.Concurrency.IScheduler scheduler) { } } public abstract class SubjectBase : System.IDisposable, System.IObservable, System.IObserver, System.Reactive.Subjects.ISubject, System.Reactive.Subjects.ISubject { protected SubjectBase() { } public abstract bool HasObservers { get; } public abstract bool IsDisposed { get; } public abstract void Dispose(); public abstract void OnCompleted(); public abstract void OnError(System.Exception error); public abstract void OnNext(T value); public abstract System.IDisposable Subscribe(System.IObserver observer); } public sealed class Subject : System.Reactive.Subjects.SubjectBase { public Subject() { } public override bool HasObservers { get; } public override bool IsDisposed { get; } public override void Dispose() { } public override void OnCompleted() { } public override void OnError(System.Exception error) { } public override void OnNext(T value) { } public override System.IDisposable Subscribe(System.IObserver observer) { } } } namespace System.Reactive.Threading.Tasks { public static class TaskObservableExtensions { public static System.IObservable ToObservable(this System.Threading.Tasks.Task task) { } public static System.IObservable ToObservable(this System.Threading.Tasks.Task task, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.IObservable ToObservable(this System.Threading.Tasks.Task task, System.Reactive.Concurrency.TaskObservationOptions options) { } public static System.IObservable ToObservable(this System.Threading.Tasks.Task task) { } public static System.IObservable ToObservable(this System.Threading.Tasks.Task task, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.IObservable ToObservable(this System.Threading.Tasks.Task task, System.Reactive.Concurrency.TaskObservationOptions options) { } public static System.Threading.Tasks.Task ToTask(this System.IObservable observable) { } public static System.Threading.Tasks.Task ToTask(this System.IObservable observable, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Threading.Tasks.Task ToTask(this System.IObservable observable, System.Threading.CancellationToken cancellationToken) { } public static System.Threading.Tasks.Task ToTask(this System.IObservable observable, object? state) { } public static System.Threading.Tasks.Task ToTask(this System.IObservable observable, System.Threading.CancellationToken cancellationToken, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Threading.Tasks.Task ToTask(this System.IObservable observable, System.Threading.CancellationToken cancellationToken, object? state) { } public static System.Threading.Tasks.Task ToTask(this System.IObservable observable, object? state, System.Reactive.Concurrency.IScheduler scheduler) { } public static System.Threading.Tasks.Task ToTask(this System.IObservable observable, System.Threading.CancellationToken cancellationToken, object? state, System.Reactive.Concurrency.IScheduler scheduler) { } } } namespace System.Runtime.CompilerServices { public struct TaskObservableMethodBuilder { public System.Reactive.ITaskObservable Task { get; } public void AwaitOnCompleted(ref TAwaiter awaiter, ref TStateMachine stateMachine) where TAwaiter : System.Runtime.CompilerServices.INotifyCompletion where TStateMachine : System.Runtime.CompilerServices.IAsyncStateMachine { } [System.Security.SecuritySafeCritical] public void AwaitUnsafeOnCompleted(ref TAwaiter awaiter, ref TStateMachine stateMachine) where TAwaiter : System.Runtime.CompilerServices.ICriticalNotifyCompletion where TStateMachine : System.Runtime.CompilerServices.IAsyncStateMachine { } public void SetException(System.Exception exception) { } public void SetResult(T result) { } public void SetStateMachine(System.Runtime.CompilerServices.IAsyncStateMachine stateMachine) { } public void Start(ref TStateMachine stateMachine) where TStateMachine : System.Runtime.CompilerServices.IAsyncStateMachine { } public static System.Runtime.CompilerServices.TaskObservableMethodBuilder Create() { } } }