<PackageReference Include="System.Reactive" Version="6.1.0-preview.9" />

---

API Differences between 6.1.0-preview.9 and 6.0.0-preview.9

39 Additions 1 Removals

System.Reactive.Concurrency

• public sealed class TaskObservationOptions
  • public bool IgnoreExceptionsAfterUnsubscribe { get; }
  • public IScheduler Scheduler { get; }
  • public TaskObservationOptions(IScheduler scheduler, bool ignoreExceptionsAfterUnsubscribe)

System.Reactive.Disposables

• public struct SingleAssignmentDisposableValue
  • public IDisposable Disposable { get; set; }
  • public bool IsDisposed { get; }
  • public static bool op_Equality(SingleAssignmentDisposableValue left, SingleAssignmentDisposableValue right)
  • public static bool op_Inequality(SingleAssignmentDisposableValue left, SingleAssignmentDisposableValue right)
  • public void Dispose()

System.Reactive.Disposables.Fluent

• public static class DisposableExtensions
  • public static T DisposeWith<T>(this T item, CompositeDisposable compositeDisposable) where T : IDisposable

System.Reactive.Linq

• public static class Observable
  • public static IObservable<TResult> Defer<TResult>(Func<Task<IObservable<TResult>>> observableFactoryAsync, bool ignoreExceptionsAfterUnsubscribe)
  • public static IObservable<TResult> DeferAsync<TResult>(Func<CancellationToken, Task<IObservable<TResult>>> observableFactoryAsync, bool ignoreExceptionsAfterUnsubscribe)
  • public static IObservable<TResult> FromAsync<TResult>(Func<Task<TResult>> functionAsync, TaskObservationOptions options)
  • public static IObservable<TResult> FromAsync<TResult>(Func<CancellationToken, Task<TResult>> functionAsync, TaskObservationOptions options)
  • public static IObservable<Unit> FromAsync(Func<Task> actionAsync, TaskObservationOptions options)
  • public static IObservable<Unit> FromAsync(Func<CancellationToken, Task> actionAsync, TaskObservationOptions options)
  • public static IObservable<TSource> ResetExceptionDispatchState<TSource>(this IObservable<TSource> source)
  • public static IObservable<TResult> StartAsync<TResult>(Func<Task<TResult>> functionAsync, TaskObservationOptions options)
  • public static IObservable<TResult> StartAsync<TResult>(Func<CancellationToken, Task<TResult>> functionAsync, TaskObservationOptions options)
  • public static IObservable<Unit> StartAsync(Func<Task> actionAsync, TaskObservationOptions options)
  • public static IObservable<Unit> StartAsync(Func<CancellationToken, Task> actionAsync, TaskObservationOptions options)
  • public static IObservable<TSource> TakeUntil<TSource>(this IObservable<TSource> source, CancellationToken cancellationToken)
• public static class Qbservable
  • public static IQbservable<TResult> Defer<TResult>(this IQbservableProvider provider, Expression<Func<Task<IObservable<TResult>>>> observableFactoryAsync, bool ignoreExceptionsAfterUnsubscribe)
  • public static IQbservable<TResult> DeferAsync<TResult>(this IQbservableProvider provider, Expression<Func<CancellationToken, Task<IObservable<TResult>>>> observableFactoryAsync, bool ignoreExceptionsAfterUnsubscribe)
  • public static IQbservable<Unit> FromAsync(this IQbservableProvider provider, Expression<Func<Task>> actionAsync, TaskObservationOptions options)
  • public static IQbservable<Unit> FromAsync(this IQbservableProvider provider, Expression<Func<CancellationToken, Task>> actionAsync, TaskObservationOptions options)
  • public static IQbservable<TResult> FromAsync<TResult>(this IQbservableProvider provider, Expression<Func<Task<TResult>>> functionAsync, TaskObservationOptions options)
  • public static IQbservable<TResult> FromAsync<TResult>(this IQbservableProvider provider, Expression<Func<CancellationToken, Task<TResult>>> functionAsync, TaskObservationOptions options)
  • public static IQbservable<TSource> ResetExceptionDispatchState<TSource>(this IQbservable<TSource> source)
  • public static IQbservable<Unit> StartAsync(this IQbservableProvider provider, Expression<Func<Task>> actionAsync, TaskObservationOptions options)
  • public static IQbservable<Unit> StartAsync(this IQbservableProvider provider, Expression<Func<CancellationToken, Task>> actionAsync, TaskObservationOptions options)
  • public static IQbservable<TResult> StartAsync<TResult>(this IQbservableProvider provider, Expression<Func<Task<TResult>>> functionAsync, IScheduler scheduler)
  • public static IQbservable<TResult> StartAsync<TResult>(this IQbservableProvider provider, Expression<Func<CancellationToken, Task<TResult>>> functionAsync, TaskObservationOptions options)
  • public static IQbservable<TResult> StartAsync<TResult>(this IQbservableProvider provider, Expression<Func<Task<TResult>>> functionAsync, TaskObservationOptions options)
  • public static IQbservable<TResult> StartAsync<TResult>(this IQbservableProvider provider, Expression<Func<Task<TResult>>> functionAsync, IScheduler scheduler)
  • public static IQbservable<TSource> TakeUntil<TSource>(this IQbservable<TSource> source, CancellationToken cancellationToken)

System.Reactive.Threading.Tasks

• public static class TaskObservableExtensions
  • public static IObservable<Unit> ToObservable(this Task task, TaskObservationOptions options)
  • public static IObservable<TResult> ToObservable<TResult>(this Task<TResult> task, TaskObservationOptions options)