|
|
@@ -30,9 +30,9 @@ namespace System.Reactive.Linq
|
|
|
public static IObservable<IList<TSource>> Buffer<TSource>(this IObservable<TSource> source, TimeSpan timeSpan)
|
|
|
{
|
|
|
if (source == null)
|
|
|
- throw new ArgumentNullException("source");
|
|
|
+ throw new ArgumentNullException(nameof(source));
|
|
|
if (timeSpan < TimeSpan.Zero)
|
|
|
- throw new ArgumentOutOfRangeException("timeSpan");
|
|
|
+ throw new ArgumentOutOfRangeException(nameof(timeSpan));
|
|
|
|
|
|
return s_impl.Buffer<TSource>(source, timeSpan);
|
|
|
}
|
|
|
@@ -55,11 +55,11 @@ namespace System.Reactive.Linq
|
|
|
public static IObservable<IList<TSource>> Buffer<TSource>(this IObservable<TSource> source, TimeSpan timeSpan, IScheduler scheduler)
|
|
|
{
|
|
|
if (source == null)
|
|
|
- throw new ArgumentNullException("source");
|
|
|
+ throw new ArgumentNullException(nameof(source));
|
|
|
if (timeSpan < TimeSpan.Zero)
|
|
|
- throw new ArgumentOutOfRangeException("timeSpan");
|
|
|
+ throw new ArgumentOutOfRangeException(nameof(timeSpan));
|
|
|
if (scheduler == null)
|
|
|
- throw new ArgumentNullException("scheduler");
|
|
|
+ throw new ArgumentNullException(nameof(scheduler));
|
|
|
|
|
|
return s_impl.Buffer<TSource>(source, timeSpan, scheduler);
|
|
|
}
|
|
|
@@ -89,11 +89,11 @@ namespace System.Reactive.Linq
|
|
|
public static IObservable<IList<TSource>> Buffer<TSource>(this IObservable<TSource> source, TimeSpan timeSpan, TimeSpan timeShift)
|
|
|
{
|
|
|
if (source == null)
|
|
|
- throw new ArgumentNullException("source");
|
|
|
+ throw new ArgumentNullException(nameof(source));
|
|
|
if (timeSpan < TimeSpan.Zero)
|
|
|
- throw new ArgumentOutOfRangeException("timeSpan");
|
|
|
+ throw new ArgumentOutOfRangeException(nameof(timeSpan));
|
|
|
if (timeShift < TimeSpan.Zero)
|
|
|
- throw new ArgumentOutOfRangeException("timeShift");
|
|
|
+ throw new ArgumentOutOfRangeException(nameof(timeShift));
|
|
|
|
|
|
return s_impl.Buffer<TSource>(source, timeSpan, timeShift);
|
|
|
}
|
|
|
@@ -124,13 +124,13 @@ namespace System.Reactive.Linq
|
|
|
public static IObservable<IList<TSource>> Buffer<TSource>(this IObservable<TSource> source, TimeSpan timeSpan, TimeSpan timeShift, IScheduler scheduler)
|
|
|
{
|
|
|
if (source == null)
|
|
|
- throw new ArgumentNullException("source");
|
|
|
+ throw new ArgumentNullException(nameof(source));
|
|
|
if (timeSpan < TimeSpan.Zero)
|
|
|
- throw new ArgumentOutOfRangeException("timeSpan");
|
|
|
+ throw new ArgumentOutOfRangeException(nameof(timeSpan));
|
|
|
if (timeShift < TimeSpan.Zero)
|
|
|
- throw new ArgumentOutOfRangeException("timeShift");
|
|
|
+ throw new ArgumentOutOfRangeException(nameof(timeShift));
|
|
|
if (scheduler == null)
|
|
|
- throw new ArgumentNullException("scheduler");
|
|
|
+ throw new ArgumentNullException(nameof(scheduler));
|
|
|
|
|
|
return s_impl.Buffer<TSource>(source, timeSpan, timeShift, scheduler);
|
|
|
}
|
|
|
@@ -158,11 +158,11 @@ namespace System.Reactive.Linq
|
|
|
public static IObservable<IList<TSource>> Buffer<TSource>(this IObservable<TSource> source, TimeSpan timeSpan, int count)
|
|
|
{
|
|
|
if (source == null)
|
|
|
- throw new ArgumentNullException("source");
|
|
|
+ throw new ArgumentNullException(nameof(source));
|
|
|
if (timeSpan < TimeSpan.Zero)
|
|
|
- throw new ArgumentOutOfRangeException("timeSpan");
|
|
|
+ throw new ArgumentOutOfRangeException(nameof(timeSpan));
|
|
|
if (count <= 0)
|
|
|
- throw new ArgumentOutOfRangeException("count");
|
|
|
+ throw new ArgumentOutOfRangeException(nameof(count));
|
|
|
|
|
|
return s_impl.Buffer<TSource>(source, timeSpan, count);
|
|
|
}
|
|
|
@@ -187,13 +187,13 @@ namespace System.Reactive.Linq
|
|
|
public static IObservable<IList<TSource>> Buffer<TSource>(this IObservable<TSource> source, TimeSpan timeSpan, int count, IScheduler scheduler)
|
|
|
{
|
|
|
if (source == null)
|
|
|
- throw new ArgumentNullException("source");
|
|
|
+ throw new ArgumentNullException(nameof(source));
|
|
|
if (timeSpan < TimeSpan.Zero)
|
|
|
- throw new ArgumentOutOfRangeException("timeSpan");
|
|
|
+ throw new ArgumentOutOfRangeException(nameof(timeSpan));
|
|
|
if (count <= 0)
|
|
|
- throw new ArgumentOutOfRangeException("count");
|
|
|
+ throw new ArgumentOutOfRangeException(nameof(count));
|
|
|
if (scheduler == null)
|
|
|
- throw new ArgumentNullException("scheduler");
|
|
|
+ throw new ArgumentNullException(nameof(scheduler));
|
|
|
|
|
|
return s_impl.Buffer<TSource>(source, timeSpan, count, scheduler);
|
|
|
}
|
|
|
@@ -231,9 +231,9 @@ namespace System.Reactive.Linq
|
|
|
public static IObservable<TSource> Delay<TSource>(this IObservable<TSource> source, TimeSpan dueTime)
|
|
|
{
|
|
|
if (source == null)
|
|
|
- throw new ArgumentNullException("source");
|
|
|
+ throw new ArgumentNullException(nameof(source));
|
|
|
if (dueTime < TimeSpan.Zero)
|
|
|
- throw new ArgumentOutOfRangeException("dueTime");
|
|
|
+ throw new ArgumentOutOfRangeException(nameof(dueTime));
|
|
|
|
|
|
return s_impl.Delay<TSource>(source, dueTime);
|
|
|
}
|
|
|
@@ -267,11 +267,11 @@ namespace System.Reactive.Linq
|
|
|
public static IObservable<TSource> Delay<TSource>(this IObservable<TSource> source, TimeSpan dueTime, IScheduler scheduler)
|
|
|
{
|
|
|
if (source == null)
|
|
|
- throw new ArgumentNullException("source");
|
|
|
+ throw new ArgumentNullException(nameof(source));
|
|
|
if (dueTime < TimeSpan.Zero)
|
|
|
- throw new ArgumentOutOfRangeException("dueTime");
|
|
|
+ throw new ArgumentOutOfRangeException(nameof(dueTime));
|
|
|
if (scheduler == null)
|
|
|
- throw new ArgumentNullException("scheduler");
|
|
|
+ throw new ArgumentNullException(nameof(scheduler));
|
|
|
|
|
|
return s_impl.Delay<TSource>(source, dueTime, scheduler);
|
|
|
}
|
|
|
@@ -304,7 +304,7 @@ namespace System.Reactive.Linq
|
|
|
public static IObservable<TSource> Delay<TSource>(this IObservable<TSource> source, DateTimeOffset dueTime)
|
|
|
{
|
|
|
if (source == null)
|
|
|
- throw new ArgumentNullException("source");
|
|
|
+ throw new ArgumentNullException(nameof(source));
|
|
|
|
|
|
return s_impl.Delay<TSource>(source, dueTime);
|
|
|
}
|
|
|
@@ -334,9 +334,9 @@ namespace System.Reactive.Linq
|
|
|
public static IObservable<TSource> Delay<TSource>(this IObservable<TSource> source, DateTimeOffset dueTime, IScheduler scheduler)
|
|
|
{
|
|
|
if (source == null)
|
|
|
- throw new ArgumentNullException("source");
|
|
|
+ throw new ArgumentNullException(nameof(source));
|
|
|
if (scheduler == null)
|
|
|
- throw new ArgumentNullException("scheduler");
|
|
|
+ throw new ArgumentNullException(nameof(scheduler));
|
|
|
|
|
|
return s_impl.Delay<TSource>(source, dueTime, scheduler);
|
|
|
}
|
|
|
@@ -357,9 +357,9 @@ namespace System.Reactive.Linq
|
|
|
public static IObservable<TSource> Delay<TSource, TDelay>(this IObservable<TSource> source, Func<TSource, IObservable<TDelay>> delayDurationSelector)
|
|
|
{
|
|
|
if (source == null)
|
|
|
- throw new ArgumentNullException("source");
|
|
|
+ throw new ArgumentNullException(nameof(source));
|
|
|
if (delayDurationSelector == null)
|
|
|
- throw new ArgumentNullException("delayDurationSelector");
|
|
|
+ throw new ArgumentNullException(nameof(delayDurationSelector));
|
|
|
|
|
|
return s_impl.Delay<TSource, TDelay>(source, delayDurationSelector);
|
|
|
}
|
|
|
@@ -377,11 +377,11 @@ namespace System.Reactive.Linq
|
|
|
public static IObservable<TSource> Delay<TSource, TDelay>(this IObservable<TSource> source, IObservable<TDelay> subscriptionDelay, Func<TSource, IObservable<TDelay>> delayDurationSelector)
|
|
|
{
|
|
|
if (source == null)
|
|
|
- throw new ArgumentNullException("source");
|
|
|
+ throw new ArgumentNullException(nameof(source));
|
|
|
if (subscriptionDelay == null)
|
|
|
- throw new ArgumentNullException("subscriptionDelay");
|
|
|
+ throw new ArgumentNullException(nameof(subscriptionDelay));
|
|
|
if (delayDurationSelector == null)
|
|
|
- throw new ArgumentNullException("delayDurationSelector");
|
|
|
+ throw new ArgumentNullException(nameof(delayDurationSelector));
|
|
|
|
|
|
return s_impl.Delay<TSource, TDelay>(source, subscriptionDelay, delayDurationSelector);
|
|
|
}
|
|
|
@@ -412,9 +412,9 @@ namespace System.Reactive.Linq
|
|
|
public static IObservable<TSource> DelaySubscription<TSource>(this IObservable<TSource> source, TimeSpan dueTime)
|
|
|
{
|
|
|
if (source == null)
|
|
|
- throw new ArgumentNullException("source");
|
|
|
+ throw new ArgumentNullException(nameof(source));
|
|
|
if (dueTime < TimeSpan.Zero)
|
|
|
- throw new ArgumentOutOfRangeException("dueTime");
|
|
|
+ throw new ArgumentOutOfRangeException(nameof(dueTime));
|
|
|
|
|
|
return s_impl.DelaySubscription<TSource>(source, dueTime);
|
|
|
}
|
|
|
@@ -440,11 +440,11 @@ namespace System.Reactive.Linq
|
|
|
public static IObservable<TSource> DelaySubscription<TSource>(this IObservable<TSource> source, TimeSpan dueTime, IScheduler scheduler)
|
|
|
{
|
|
|
if (source == null)
|
|
|
- throw new ArgumentNullException("source");
|
|
|
+ throw new ArgumentNullException(nameof(source));
|
|
|
if (dueTime < TimeSpan.Zero)
|
|
|
- throw new ArgumentOutOfRangeException("dueTime");
|
|
|
+ throw new ArgumentOutOfRangeException(nameof(dueTime));
|
|
|
if (scheduler == null)
|
|
|
- throw new ArgumentNullException("scheduler");
|
|
|
+ throw new ArgumentNullException(nameof(scheduler));
|
|
|
|
|
|
return s_impl.DelaySubscription<TSource>(source, dueTime, scheduler);
|
|
|
}
|
|
|
@@ -468,7 +468,7 @@ namespace System.Reactive.Linq
|
|
|
public static IObservable<TSource> DelaySubscription<TSource>(this IObservable<TSource> source, DateTimeOffset dueTime)
|
|
|
{
|
|
|
if (source == null)
|
|
|
- throw new ArgumentNullException("source");
|
|
|
+ throw new ArgumentNullException(nameof(source));
|
|
|
|
|
|
return s_impl.DelaySubscription<TSource>(source, dueTime);
|
|
|
}
|
|
|
@@ -493,9 +493,9 @@ namespace System.Reactive.Linq
|
|
|
public static IObservable<TSource> DelaySubscription<TSource>(this IObservable<TSource> source, DateTimeOffset dueTime, IScheduler scheduler)
|
|
|
{
|
|
|
if (source == null)
|
|
|
- throw new ArgumentNullException("source");
|
|
|
+ throw new ArgumentNullException(nameof(source));
|
|
|
if (scheduler == null)
|
|
|
- throw new ArgumentNullException("scheduler");
|
|
|
+ throw new ArgumentNullException(nameof(scheduler));
|
|
|
|
|
|
return s_impl.DelaySubscription<TSource>(source, dueTime, scheduler);
|
|
|
}
|
|
|
@@ -519,13 +519,13 @@ namespace System.Reactive.Linq
|
|
|
public static IObservable<TResult> Generate<TState, TResult>(TState initialState, Func<TState, bool> condition, Func<TState, TState> iterate, Func<TState, TResult> resultSelector, Func<TState, TimeSpan> timeSelector)
|
|
|
{
|
|
|
if (condition == null)
|
|
|
- throw new ArgumentNullException("condition");
|
|
|
+ throw new ArgumentNullException(nameof(condition));
|
|
|
if (iterate == null)
|
|
|
- throw new ArgumentNullException("iterate");
|
|
|
+ throw new ArgumentNullException(nameof(iterate));
|
|
|
if (resultSelector == null)
|
|
|
- throw new ArgumentNullException("resultSelector");
|
|
|
+ throw new ArgumentNullException(nameof(resultSelector));
|
|
|
if (timeSelector == null)
|
|
|
- throw new ArgumentNullException("timeSelector");
|
|
|
+ throw new ArgumentNullException(nameof(timeSelector));
|
|
|
|
|
|
return s_impl.Generate<TState, TResult>(initialState, condition, iterate, resultSelector, timeSelector);
|
|
|
}
|
|
|
@@ -546,15 +546,15 @@ namespace System.Reactive.Linq
|
|
|
public static IObservable<TResult> Generate<TState, TResult>(TState initialState, Func<TState, bool> condition, Func<TState, TState> iterate, Func<TState, TResult> resultSelector, Func<TState, TimeSpan> timeSelector, IScheduler scheduler)
|
|
|
{
|
|
|
if (condition == null)
|
|
|
- throw new ArgumentNullException("condition");
|
|
|
+ throw new ArgumentNullException(nameof(condition));
|
|
|
if (iterate == null)
|
|
|
- throw new ArgumentNullException("iterate");
|
|
|
+ throw new ArgumentNullException(nameof(iterate));
|
|
|
if (resultSelector == null)
|
|
|
- throw new ArgumentNullException("resultSelector");
|
|
|
+ throw new ArgumentNullException(nameof(resultSelector));
|
|
|
if (timeSelector == null)
|
|
|
- throw new ArgumentNullException("timeSelector");
|
|
|
+ throw new ArgumentNullException(nameof(timeSelector));
|
|
|
if (scheduler == null)
|
|
|
- throw new ArgumentNullException("scheduler");
|
|
|
+ throw new ArgumentNullException(nameof(scheduler));
|
|
|
|
|
|
return s_impl.Generate<TState, TResult>(initialState, condition, iterate, resultSelector, timeSelector, scheduler);
|
|
|
}
|
|
|
@@ -574,13 +574,13 @@ namespace System.Reactive.Linq
|
|
|
public static IObservable<TResult> Generate<TState, TResult>(TState initialState, Func<TState, bool> condition, Func<TState, TState> iterate, Func<TState, TResult> resultSelector, Func<TState, DateTimeOffset> timeSelector)
|
|
|
{
|
|
|
if (condition == null)
|
|
|
- throw new ArgumentNullException("condition");
|
|
|
+ throw new ArgumentNullException(nameof(condition));
|
|
|
if (iterate == null)
|
|
|
- throw new ArgumentNullException("iterate");
|
|
|
+ throw new ArgumentNullException(nameof(iterate));
|
|
|
if (resultSelector == null)
|
|
|
- throw new ArgumentNullException("resultSelector");
|
|
|
+ throw new ArgumentNullException(nameof(resultSelector));
|
|
|
if (timeSelector == null)
|
|
|
- throw new ArgumentNullException("timeSelector");
|
|
|
+ throw new ArgumentNullException(nameof(timeSelector));
|
|
|
|
|
|
return s_impl.Generate<TState, TResult>(initialState, condition, iterate, resultSelector, timeSelector);
|
|
|
}
|
|
|
@@ -601,15 +601,15 @@ namespace System.Reactive.Linq
|
|
|
public static IObservable<TResult> Generate<TState, TResult>(TState initialState, Func<TState, bool> condition, Func<TState, TState> iterate, Func<TState, TResult> resultSelector, Func<TState, DateTimeOffset> timeSelector, IScheduler scheduler)
|
|
|
{
|
|
|
if (condition == null)
|
|
|
- throw new ArgumentNullException("condition");
|
|
|
+ throw new ArgumentNullException(nameof(condition));
|
|
|
if (iterate == null)
|
|
|
- throw new ArgumentNullException("iterate");
|
|
|
+ throw new ArgumentNullException(nameof(iterate));
|
|
|
if (resultSelector == null)
|
|
|
- throw new ArgumentNullException("resultSelector");
|
|
|
+ throw new ArgumentNullException(nameof(resultSelector));
|
|
|
if (timeSelector == null)
|
|
|
- throw new ArgumentNullException("timeSelector");
|
|
|
+ throw new ArgumentNullException(nameof(timeSelector));
|
|
|
if (scheduler == null)
|
|
|
- throw new ArgumentNullException("scheduler");
|
|
|
+ throw new ArgumentNullException(nameof(scheduler));
|
|
|
|
|
|
return s_impl.Generate<TState, TResult>(initialState, condition, iterate, resultSelector, timeSelector, scheduler);
|
|
|
}
|
|
|
@@ -634,7 +634,7 @@ namespace System.Reactive.Linq
|
|
|
public static IObservable<long> Interval(TimeSpan period)
|
|
|
{
|
|
|
if (period < TimeSpan.Zero)
|
|
|
- throw new ArgumentOutOfRangeException("period");
|
|
|
+ throw new ArgumentOutOfRangeException(nameof(period));
|
|
|
|
|
|
return s_impl.Interval(period);
|
|
|
}
|
|
|
@@ -657,9 +657,9 @@ namespace System.Reactive.Linq
|
|
|
public static IObservable<long> Interval(TimeSpan period, IScheduler scheduler)
|
|
|
{
|
|
|
if (period < TimeSpan.Zero)
|
|
|
- throw new ArgumentOutOfRangeException("period");
|
|
|
+ throw new ArgumentOutOfRangeException(nameof(period));
|
|
|
if (scheduler == null)
|
|
|
- throw new ArgumentNullException("scheduler");
|
|
|
+ throw new ArgumentNullException(nameof(scheduler));
|
|
|
|
|
|
return s_impl.Interval(period, scheduler);
|
|
|
}
|
|
|
@@ -685,9 +685,9 @@ namespace System.Reactive.Linq
|
|
|
public static IObservable<TSource> Sample<TSource>(this IObservable<TSource> source, TimeSpan interval)
|
|
|
{
|
|
|
if (source == null)
|
|
|
- throw new ArgumentNullException("source");
|
|
|
+ throw new ArgumentNullException(nameof(source));
|
|
|
if (interval < TimeSpan.Zero)
|
|
|
- throw new ArgumentOutOfRangeException("interval");
|
|
|
+ throw new ArgumentOutOfRangeException(nameof(interval));
|
|
|
|
|
|
return s_impl.Sample<TSource>(source, interval);
|
|
|
}
|
|
|
@@ -710,11 +710,11 @@ namespace System.Reactive.Linq
|
|
|
public static IObservable<TSource> Sample<TSource>(this IObservable<TSource> source, TimeSpan interval, IScheduler scheduler)
|
|
|
{
|
|
|
if (source == null)
|
|
|
- throw new ArgumentNullException("source");
|
|
|
+ throw new ArgumentNullException(nameof(source));
|
|
|
if (interval < TimeSpan.Zero)
|
|
|
- throw new ArgumentOutOfRangeException("interval");
|
|
|
+ throw new ArgumentOutOfRangeException(nameof(interval));
|
|
|
if (scheduler == null)
|
|
|
- throw new ArgumentNullException("scheduler");
|
|
|
+ throw new ArgumentNullException(nameof(scheduler));
|
|
|
|
|
|
return s_impl.Sample<TSource>(source, interval, scheduler);
|
|
|
}
|
|
|
@@ -732,9 +732,9 @@ namespace System.Reactive.Linq
|
|
|
public static IObservable<TSource> Sample<TSource, TSample>(this IObservable<TSource> source, IObservable<TSample> sampler)
|
|
|
{
|
|
|
if (source == null)
|
|
|
- throw new ArgumentNullException("source");
|
|
|
+ throw new ArgumentNullException(nameof(source));
|
|
|
if (sampler == null)
|
|
|
- throw new ArgumentNullException("sampler");
|
|
|
+ throw new ArgumentNullException(nameof(sampler));
|
|
|
|
|
|
return s_impl.Sample<TSource, TSample>(source, sampler);
|
|
|
}
|
|
|
@@ -765,9 +765,9 @@ namespace System.Reactive.Linq
|
|
|
public static IObservable<TSource> Skip<TSource>(this IObservable<TSource> source, TimeSpan duration)
|
|
|
{
|
|
|
if (source == null)
|
|
|
- throw new ArgumentNullException("source");
|
|
|
+ throw new ArgumentNullException(nameof(source));
|
|
|
if (duration < TimeSpan.Zero)
|
|
|
- throw new ArgumentOutOfRangeException("duration");
|
|
|
+ throw new ArgumentOutOfRangeException(nameof(duration));
|
|
|
|
|
|
return s_impl.Skip<TSource>(source, duration);
|
|
|
}
|
|
|
@@ -795,11 +795,11 @@ namespace System.Reactive.Linq
|
|
|
public static IObservable<TSource> Skip<TSource>(this IObservable<TSource> source, TimeSpan duration, IScheduler scheduler)
|
|
|
{
|
|
|
if (source == null)
|
|
|
- throw new ArgumentNullException("source");
|
|
|
+ throw new ArgumentNullException(nameof(source));
|
|
|
if (duration < TimeSpan.Zero)
|
|
|
- throw new ArgumentOutOfRangeException("duration");
|
|
|
+ throw new ArgumentOutOfRangeException(nameof(duration));
|
|
|
if (scheduler == null)
|
|
|
- throw new ArgumentNullException("scheduler");
|
|
|
+ throw new ArgumentNullException(nameof(scheduler));
|
|
|
|
|
|
return s_impl.Skip<TSource>(source, duration, scheduler);
|
|
|
}
|
|
|
@@ -825,9 +825,9 @@ namespace System.Reactive.Linq
|
|
|
public static IObservable<TSource> SkipLast<TSource>(this IObservable<TSource> source, TimeSpan duration)
|
|
|
{
|
|
|
if (source == null)
|
|
|
- throw new ArgumentNullException("source");
|
|
|
+ throw new ArgumentNullException(nameof(source));
|
|
|
if (duration < TimeSpan.Zero)
|
|
|
- throw new ArgumentOutOfRangeException("duration");
|
|
|
+ throw new ArgumentOutOfRangeException(nameof(duration));
|
|
|
|
|
|
return s_impl.SkipLast<TSource>(source, duration);
|
|
|
}
|
|
|
@@ -850,11 +850,11 @@ namespace System.Reactive.Linq
|
|
|
public static IObservable<TSource> SkipLast<TSource>(this IObservable<TSource> source, TimeSpan duration, IScheduler scheduler)
|
|
|
{
|
|
|
if (source == null)
|
|
|
- throw new ArgumentNullException("source");
|
|
|
+ throw new ArgumentNullException(nameof(source));
|
|
|
if (duration < TimeSpan.Zero)
|
|
|
- throw new ArgumentOutOfRangeException("duration");
|
|
|
+ throw new ArgumentOutOfRangeException(nameof(duration));
|
|
|
if (scheduler == null)
|
|
|
- throw new ArgumentNullException("scheduler");
|
|
|
+ throw new ArgumentNullException(nameof(scheduler));
|
|
|
|
|
|
return s_impl.SkipLast<TSource>(source, duration, scheduler);
|
|
|
}
|
|
|
@@ -877,7 +877,7 @@ namespace System.Reactive.Linq
|
|
|
public static IObservable<TSource> SkipUntil<TSource>(this IObservable<TSource> source, DateTimeOffset startTime)
|
|
|
{
|
|
|
if (source == null)
|
|
|
- throw new ArgumentNullException("source");
|
|
|
+ throw new ArgumentNullException(nameof(source));
|
|
|
|
|
|
return s_impl.SkipUntil<TSource>(source, startTime);
|
|
|
}
|
|
|
@@ -897,9 +897,9 @@ namespace System.Reactive.Linq
|
|
|
public static IObservable<TSource> SkipUntil<TSource>(this IObservable<TSource> source, DateTimeOffset startTime, IScheduler scheduler)
|
|
|
{
|
|
|
if (source == null)
|
|
|
- throw new ArgumentNullException("source");
|
|
|
+ throw new ArgumentNullException(nameof(source));
|
|
|
if (scheduler == null)
|
|
|
- throw new ArgumentNullException("scheduler");
|
|
|
+ throw new ArgumentNullException(nameof(scheduler));
|
|
|
|
|
|
return s_impl.SkipUntil<TSource>(source, startTime, scheduler);
|
|
|
}
|
|
|
@@ -925,9 +925,9 @@ namespace System.Reactive.Linq
|
|
|
public static IObservable<TSource> Take<TSource>(this IObservable<TSource> source, TimeSpan duration)
|
|
|
{
|
|
|
if (source == null)
|
|
|
- throw new ArgumentNullException("source");
|
|
|
+ throw new ArgumentNullException(nameof(source));
|
|
|
if (duration < TimeSpan.Zero)
|
|
|
- throw new ArgumentOutOfRangeException("duration");
|
|
|
+ throw new ArgumentOutOfRangeException(nameof(duration));
|
|
|
|
|
|
return s_impl.Take<TSource>(source, duration);
|
|
|
}
|
|
|
@@ -950,11 +950,11 @@ namespace System.Reactive.Linq
|
|
|
public static IObservable<TSource> Take<TSource>(this IObservable<TSource> source, TimeSpan duration, IScheduler scheduler)
|
|
|
{
|
|
|
if (source == null)
|
|
|
- throw new ArgumentNullException("source");
|
|
|
+ throw new ArgumentNullException(nameof(source));
|
|
|
if (duration < TimeSpan.Zero)
|
|
|
- throw new ArgumentOutOfRangeException("duration");
|
|
|
+ throw new ArgumentOutOfRangeException(nameof(duration));
|
|
|
if (scheduler == null)
|
|
|
- throw new ArgumentNullException("scheduler");
|
|
|
+ throw new ArgumentNullException(nameof(scheduler));
|
|
|
|
|
|
return s_impl.Take<TSource>(source, duration, scheduler);
|
|
|
}
|
|
|
@@ -980,9 +980,9 @@ namespace System.Reactive.Linq
|
|
|
public static IObservable<TSource> TakeLast<TSource>(this IObservable<TSource> source, TimeSpan duration)
|
|
|
{
|
|
|
if (source == null)
|
|
|
- throw new ArgumentNullException("source");
|
|
|
+ throw new ArgumentNullException(nameof(source));
|
|
|
if (duration < TimeSpan.Zero)
|
|
|
- throw new ArgumentOutOfRangeException("duration");
|
|
|
+ throw new ArgumentOutOfRangeException(nameof(duration));
|
|
|
|
|
|
return s_impl.TakeLast<TSource>(source, duration);
|
|
|
}
|
|
|
@@ -1005,11 +1005,11 @@ namespace System.Reactive.Linq
|
|
|
public static IObservable<TSource> TakeLast<TSource>(this IObservable<TSource> source, TimeSpan duration, IScheduler scheduler)
|
|
|
{
|
|
|
if (source == null)
|
|
|
- throw new ArgumentNullException("source");
|
|
|
+ throw new ArgumentNullException(nameof(source));
|
|
|
if (duration < TimeSpan.Zero)
|
|
|
- throw new ArgumentOutOfRangeException("duration");
|
|
|
+ throw new ArgumentOutOfRangeException(nameof(duration));
|
|
|
if (scheduler == null)
|
|
|
- throw new ArgumentNullException("scheduler");
|
|
|
+ throw new ArgumentNullException(nameof(scheduler));
|
|
|
|
|
|
return s_impl.TakeLast<TSource>(source, duration, scheduler);
|
|
|
}
|
|
|
@@ -1033,13 +1033,13 @@ namespace System.Reactive.Linq
|
|
|
public static IObservable<TSource> TakeLast<TSource>(this IObservable<TSource> source, TimeSpan duration, IScheduler timerScheduler, IScheduler loopScheduler)
|
|
|
{
|
|
|
if (source == null)
|
|
|
- throw new ArgumentNullException("source");
|
|
|
+ throw new ArgumentNullException(nameof(source));
|
|
|
if (duration < TimeSpan.Zero)
|
|
|
- throw new ArgumentOutOfRangeException("duration");
|
|
|
+ throw new ArgumentOutOfRangeException(nameof(duration));
|
|
|
if (timerScheduler == null)
|
|
|
- throw new ArgumentNullException("timerScheduler");
|
|
|
+ throw new ArgumentNullException(nameof(timerScheduler));
|
|
|
if (loopScheduler == null)
|
|
|
- throw new ArgumentNullException("loopScheduler");
|
|
|
+ throw new ArgumentNullException(nameof(loopScheduler));
|
|
|
|
|
|
return s_impl.TakeLast<TSource>(source, duration, timerScheduler, loopScheduler);
|
|
|
}
|
|
|
@@ -1064,9 +1064,9 @@ namespace System.Reactive.Linq
|
|
|
public static IObservable<IList<TSource>> TakeLastBuffer<TSource>(this IObservable<TSource> source, TimeSpan duration)
|
|
|
{
|
|
|
if (source == null)
|
|
|
- throw new ArgumentNullException("source");
|
|
|
+ throw new ArgumentNullException(nameof(source));
|
|
|
if (duration < TimeSpan.Zero)
|
|
|
- throw new ArgumentOutOfRangeException("duration");
|
|
|
+ throw new ArgumentOutOfRangeException(nameof(duration));
|
|
|
|
|
|
return s_impl.TakeLastBuffer<TSource>(source, duration);
|
|
|
}
|
|
|
@@ -1088,11 +1088,11 @@ namespace System.Reactive.Linq
|
|
|
public static IObservable<IList<TSource>> TakeLastBuffer<TSource>(this IObservable<TSource> source, TimeSpan duration, IScheduler scheduler)
|
|
|
{
|
|
|
if (source == null)
|
|
|
- throw new ArgumentNullException("source");
|
|
|
+ throw new ArgumentNullException(nameof(source));
|
|
|
if (duration < TimeSpan.Zero)
|
|
|
- throw new ArgumentOutOfRangeException("duration");
|
|
|
+ throw new ArgumentOutOfRangeException(nameof(duration));
|
|
|
if (scheduler == null)
|
|
|
- throw new ArgumentNullException("scheduler");
|
|
|
+ throw new ArgumentNullException(nameof(scheduler));
|
|
|
|
|
|
return s_impl.TakeLastBuffer<TSource>(source, duration, scheduler);
|
|
|
}
|
|
|
@@ -1112,7 +1112,7 @@ namespace System.Reactive.Linq
|
|
|
public static IObservable<TSource> TakeUntil<TSource>(this IObservable<TSource> source, DateTimeOffset endTime)
|
|
|
{
|
|
|
if (source == null)
|
|
|
- throw new ArgumentNullException("source");
|
|
|
+ throw new ArgumentNullException(nameof(source));
|
|
|
|
|
|
return s_impl.TakeUntil<TSource>(source, endTime);
|
|
|
}
|
|
|
@@ -1129,9 +1129,9 @@ namespace System.Reactive.Linq
|
|
|
public static IObservable<TSource> TakeUntil<TSource>(this IObservable<TSource> source, DateTimeOffset endTime, IScheduler scheduler)
|
|
|
{
|
|
|
if (source == null)
|
|
|
- throw new ArgumentNullException("source");
|
|
|
+ throw new ArgumentNullException(nameof(source));
|
|
|
if (scheduler == null)
|
|
|
- throw new ArgumentNullException("scheduler");
|
|
|
+ throw new ArgumentNullException(nameof(scheduler));
|
|
|
|
|
|
return s_impl.TakeUntil<TSource>(source, endTime, scheduler);
|
|
|
}
|
|
|
@@ -1167,9 +1167,9 @@ namespace System.Reactive.Linq
|
|
|
public static IObservable<TSource> Throttle<TSource>(this IObservable<TSource> source, TimeSpan dueTime)
|
|
|
{
|
|
|
if (source == null)
|
|
|
- throw new ArgumentNullException("source");
|
|
|
+ throw new ArgumentNullException(nameof(source));
|
|
|
if (dueTime < TimeSpan.Zero)
|
|
|
- throw new ArgumentOutOfRangeException("dueTime");
|
|
|
+ throw new ArgumentOutOfRangeException(nameof(dueTime));
|
|
|
|
|
|
return s_impl.Throttle<TSource>(source, dueTime);
|
|
|
}
|
|
|
@@ -1202,11 +1202,11 @@ namespace System.Reactive.Linq
|
|
|
public static IObservable<TSource> Throttle<TSource>(this IObservable<TSource> source, TimeSpan dueTime, IScheduler scheduler)
|
|
|
{
|
|
|
if (source == null)
|
|
|
- throw new ArgumentNullException("source");
|
|
|
+ throw new ArgumentNullException(nameof(source));
|
|
|
if (dueTime < TimeSpan.Zero)
|
|
|
- throw new ArgumentOutOfRangeException("dueTime");
|
|
|
+ throw new ArgumentOutOfRangeException(nameof(dueTime));
|
|
|
if (scheduler == null)
|
|
|
- throw new ArgumentNullException("scheduler");
|
|
|
+ throw new ArgumentNullException(nameof(scheduler));
|
|
|
|
|
|
return s_impl.Throttle<TSource>(source, dueTime, scheduler);
|
|
|
}
|
|
|
@@ -1230,9 +1230,9 @@ namespace System.Reactive.Linq
|
|
|
public static IObservable<TSource> Throttle<TSource, TThrottle>(this IObservable<TSource> source, Func<TSource, IObservable<TThrottle>> throttleDurationSelector)
|
|
|
{
|
|
|
if (source == null)
|
|
|
- throw new ArgumentNullException("source");
|
|
|
+ throw new ArgumentNullException(nameof(source));
|
|
|
if (throttleDurationSelector == null)
|
|
|
- throw new ArgumentNullException("throttleDurationSelector");
|
|
|
+ throw new ArgumentNullException(nameof(throttleDurationSelector));
|
|
|
|
|
|
return s_impl.Throttle<TSource, TThrottle>(source, throttleDurationSelector);
|
|
|
}
|
|
|
@@ -1251,7 +1251,7 @@ namespace System.Reactive.Linq
|
|
|
public static IObservable<System.Reactive.TimeInterval<TSource>> TimeInterval<TSource>(this IObservable<TSource> source)
|
|
|
{
|
|
|
if (source == null)
|
|
|
- throw new ArgumentNullException("source");
|
|
|
+ throw new ArgumentNullException(nameof(source));
|
|
|
|
|
|
return s_impl.TimeInterval<TSource>(source);
|
|
|
}
|
|
|
@@ -1267,9 +1267,9 @@ namespace System.Reactive.Linq
|
|
|
public static IObservable<System.Reactive.TimeInterval<TSource>> TimeInterval<TSource>(this IObservable<TSource> source, IScheduler scheduler)
|
|
|
{
|
|
|
if (source == null)
|
|
|
- throw new ArgumentNullException("source");
|
|
|
+ throw new ArgumentNullException(nameof(source));
|
|
|
if (scheduler == null)
|
|
|
- throw new ArgumentNullException("scheduler");
|
|
|
+ throw new ArgumentNullException(nameof(scheduler));
|
|
|
|
|
|
return s_impl.TimeInterval<TSource>(source, scheduler);
|
|
|
}
|
|
|
@@ -1307,9 +1307,9 @@ namespace System.Reactive.Linq
|
|
|
public static IObservable<TSource> Timeout<TSource>(this IObservable<TSource> source, TimeSpan dueTime)
|
|
|
{
|
|
|
if (source == null)
|
|
|
- throw new ArgumentNullException("source");
|
|
|
+ throw new ArgumentNullException(nameof(source));
|
|
|
if (dueTime < TimeSpan.Zero)
|
|
|
- throw new ArgumentOutOfRangeException("dueTime");
|
|
|
+ throw new ArgumentOutOfRangeException(nameof(dueTime));
|
|
|
|
|
|
return s_impl.Timeout<TSource>(source, dueTime);
|
|
|
}
|
|
|
@@ -1342,11 +1342,11 @@ namespace System.Reactive.Linq
|
|
|
public static IObservable<TSource> Timeout<TSource>(this IObservable<TSource> source, TimeSpan dueTime, IScheduler scheduler)
|
|
|
{
|
|
|
if (source == null)
|
|
|
- throw new ArgumentNullException("source");
|
|
|
+ throw new ArgumentNullException(nameof(source));
|
|
|
if (dueTime < TimeSpan.Zero)
|
|
|
- throw new ArgumentOutOfRangeException("dueTime");
|
|
|
+ throw new ArgumentOutOfRangeException(nameof(dueTime));
|
|
|
if (scheduler == null)
|
|
|
- throw new ArgumentNullException("scheduler");
|
|
|
+ throw new ArgumentNullException(nameof(scheduler));
|
|
|
|
|
|
return s_impl.Timeout<TSource>(source, dueTime, scheduler);
|
|
|
}
|
|
|
@@ -1378,11 +1378,11 @@ namespace System.Reactive.Linq
|
|
|
public static IObservable<TSource> Timeout<TSource>(this IObservable<TSource> source, TimeSpan dueTime, IObservable<TSource> other)
|
|
|
{
|
|
|
if (source == null)
|
|
|
- throw new ArgumentNullException("source");
|
|
|
+ throw new ArgumentNullException(nameof(source));
|
|
|
if (dueTime < TimeSpan.Zero)
|
|
|
- throw new ArgumentOutOfRangeException("dueTime");
|
|
|
+ throw new ArgumentOutOfRangeException(nameof(dueTime));
|
|
|
if (other == null)
|
|
|
- throw new ArgumentNullException("other");
|
|
|
+ throw new ArgumentNullException(nameof(other));
|
|
|
|
|
|
return s_impl.Timeout<TSource>(source, dueTime, other);
|
|
|
}
|
|
|
@@ -1415,13 +1415,13 @@ namespace System.Reactive.Linq
|
|
|
public static IObservable<TSource> Timeout<TSource>(this IObservable<TSource> source, TimeSpan dueTime, IObservable<TSource> other, IScheduler scheduler)
|
|
|
{
|
|
|
if (source == null)
|
|
|
- throw new ArgumentNullException("source");
|
|
|
+ throw new ArgumentNullException(nameof(source));
|
|
|
if (dueTime < TimeSpan.Zero)
|
|
|
- throw new ArgumentOutOfRangeException("dueTime");
|
|
|
+ throw new ArgumentOutOfRangeException(nameof(dueTime));
|
|
|
if (other == null)
|
|
|
- throw new ArgumentNullException("other");
|
|
|
+ throw new ArgumentNullException(nameof(other));
|
|
|
if (scheduler == null)
|
|
|
- throw new ArgumentNullException("scheduler");
|
|
|
+ throw new ArgumentNullException(nameof(scheduler));
|
|
|
|
|
|
return s_impl.Timeout<TSource>(source, dueTime, other, scheduler);
|
|
|
}
|
|
|
@@ -1448,7 +1448,7 @@ namespace System.Reactive.Linq
|
|
|
public static IObservable<TSource> Timeout<TSource>(this IObservable<TSource> source, DateTimeOffset dueTime)
|
|
|
{
|
|
|
if (source == null)
|
|
|
- throw new ArgumentNullException("source");
|
|
|
+ throw new ArgumentNullException(nameof(source));
|
|
|
|
|
|
return s_impl.Timeout<TSource>(source, dueTime);
|
|
|
}
|
|
|
@@ -1472,9 +1472,9 @@ namespace System.Reactive.Linq
|
|
|
public static IObservable<TSource> Timeout<TSource>(this IObservable<TSource> source, DateTimeOffset dueTime, IScheduler scheduler)
|
|
|
{
|
|
|
if (source == null)
|
|
|
- throw new ArgumentNullException("source");
|
|
|
+ throw new ArgumentNullException(nameof(source));
|
|
|
if (scheduler == null)
|
|
|
- throw new ArgumentNullException("scheduler");
|
|
|
+ throw new ArgumentNullException(nameof(scheduler));
|
|
|
|
|
|
return s_impl.Timeout<TSource>(source, dueTime, scheduler);
|
|
|
}
|
|
|
@@ -1497,9 +1497,9 @@ namespace System.Reactive.Linq
|
|
|
public static IObservable<TSource> Timeout<TSource>(this IObservable<TSource> source, DateTimeOffset dueTime, IObservable<TSource> other)
|
|
|
{
|
|
|
if (source == null)
|
|
|
- throw new ArgumentNullException("source");
|
|
|
+ throw new ArgumentNullException(nameof(source));
|
|
|
if (other == null)
|
|
|
- throw new ArgumentNullException("other");
|
|
|
+ throw new ArgumentNullException(nameof(other));
|
|
|
|
|
|
return s_impl.Timeout<TSource>(source, dueTime, other);
|
|
|
}
|
|
|
@@ -1523,11 +1523,11 @@ namespace System.Reactive.Linq
|
|
|
public static IObservable<TSource> Timeout<TSource>(this IObservable<TSource> source, DateTimeOffset dueTime, IObservable<TSource> other, IScheduler scheduler)
|
|
|
{
|
|
|
if (source == null)
|
|
|
- throw new ArgumentNullException("source");
|
|
|
+ throw new ArgumentNullException(nameof(source));
|
|
|
if (scheduler == null)
|
|
|
- throw new ArgumentNullException("scheduler");
|
|
|
+ throw new ArgumentNullException(nameof(scheduler));
|
|
|
if (other == null)
|
|
|
- throw new ArgumentNullException("other");
|
|
|
+ throw new ArgumentNullException(nameof(other));
|
|
|
|
|
|
return s_impl.Timeout<TSource>(source, dueTime, other, scheduler);
|
|
|
}
|
|
|
@@ -1549,9 +1549,9 @@ namespace System.Reactive.Linq
|
|
|
public static IObservable<TSource> Timeout<TSource, TTimeout>(this IObservable<TSource> source, Func<TSource, IObservable<TTimeout>> timeoutDurationSelector)
|
|
|
{
|
|
|
if (source == null)
|
|
|
- throw new ArgumentNullException("source");
|
|
|
+ throw new ArgumentNullException(nameof(source));
|
|
|
if (timeoutDurationSelector == null)
|
|
|
- throw new ArgumentNullException("timeoutDurationSelector");
|
|
|
+ throw new ArgumentNullException(nameof(timeoutDurationSelector));
|
|
|
|
|
|
return s_impl.Timeout<TSource, TTimeout>(source, timeoutDurationSelector);
|
|
|
}
|
|
|
@@ -1570,11 +1570,11 @@ namespace System.Reactive.Linq
|
|
|
public static IObservable<TSource> Timeout<TSource, TTimeout>(this IObservable<TSource> source, Func<TSource, IObservable<TTimeout>> timeoutDurationSelector, IObservable<TSource> other)
|
|
|
{
|
|
|
if (source == null)
|
|
|
- throw new ArgumentNullException("source");
|
|
|
+ throw new ArgumentNullException(nameof(source));
|
|
|
if (timeoutDurationSelector == null)
|
|
|
- throw new ArgumentNullException("timeoutDurationSelector");
|
|
|
+ throw new ArgumentNullException(nameof(timeoutDurationSelector));
|
|
|
if (other == null)
|
|
|
- throw new ArgumentNullException("other");
|
|
|
+ throw new ArgumentNullException(nameof(other));
|
|
|
|
|
|
return s_impl.Timeout<TSource, TTimeout>(source, timeoutDurationSelector, other);
|
|
|
}
|
|
|
@@ -1593,11 +1593,11 @@ namespace System.Reactive.Linq
|
|
|
public static IObservable<TSource> Timeout<TSource, TTimeout>(this IObservable<TSource> source, IObservable<TTimeout> firstTimeout, Func<TSource, IObservable<TTimeout>> timeoutDurationSelector)
|
|
|
{
|
|
|
if (source == null)
|
|
|
- throw new ArgumentNullException("source");
|
|
|
+ throw new ArgumentNullException(nameof(source));
|
|
|
if (firstTimeout == null)
|
|
|
- throw new ArgumentNullException("firstTimeout");
|
|
|
+ throw new ArgumentNullException(nameof(firstTimeout));
|
|
|
if (timeoutDurationSelector == null)
|
|
|
- throw new ArgumentNullException("timeoutDurationSelector");
|
|
|
+ throw new ArgumentNullException(nameof(timeoutDurationSelector));
|
|
|
|
|
|
return s_impl.Timeout<TSource, TTimeout>(source, firstTimeout, timeoutDurationSelector);
|
|
|
}
|
|
|
@@ -1617,13 +1617,13 @@ namespace System.Reactive.Linq
|
|
|
public static IObservable<TSource> Timeout<TSource, TTimeout>(this IObservable<TSource> source, IObservable<TTimeout> firstTimeout, Func<TSource, IObservable<TTimeout>> timeoutDurationSelector, IObservable<TSource> other)
|
|
|
{
|
|
|
if (source == null)
|
|
|
- throw new ArgumentNullException("source");
|
|
|
+ throw new ArgumentNullException(nameof(source));
|
|
|
if (firstTimeout == null)
|
|
|
- throw new ArgumentNullException("firstTimeout");
|
|
|
+ throw new ArgumentNullException(nameof(firstTimeout));
|
|
|
if (timeoutDurationSelector == null)
|
|
|
- throw new ArgumentNullException("timeoutDurationSelector");
|
|
|
+ throw new ArgumentNullException(nameof(timeoutDurationSelector));
|
|
|
if (other == null)
|
|
|
- throw new ArgumentNullException("other");
|
|
|
+ throw new ArgumentNullException(nameof(other));
|
|
|
|
|
|
return s_impl.Timeout<TSource, TTimeout>(source, firstTimeout, timeoutDurationSelector, other);
|
|
|
}
|
|
|
@@ -1664,7 +1664,7 @@ namespace System.Reactive.Linq
|
|
|
public static IObservable<long> Timer(TimeSpan dueTime, TimeSpan period)
|
|
|
{
|
|
|
if (period < TimeSpan.Zero)
|
|
|
- throw new ArgumentOutOfRangeException("period");
|
|
|
+ throw new ArgumentOutOfRangeException(nameof(period));
|
|
|
|
|
|
return s_impl.Timer(dueTime, period);
|
|
|
}
|
|
|
@@ -1679,7 +1679,7 @@ namespace System.Reactive.Linq
|
|
|
public static IObservable<long> Timer(DateTimeOffset dueTime, TimeSpan period)
|
|
|
{
|
|
|
if (period < TimeSpan.Zero)
|
|
|
- throw new ArgumentOutOfRangeException("period");
|
|
|
+ throw new ArgumentOutOfRangeException(nameof(period));
|
|
|
|
|
|
return s_impl.Timer(dueTime, period);
|
|
|
}
|
|
|
@@ -1694,7 +1694,7 @@ namespace System.Reactive.Linq
|
|
|
public static IObservable<long> Timer(TimeSpan dueTime, IScheduler scheduler)
|
|
|
{
|
|
|
if (scheduler == null)
|
|
|
- throw new ArgumentNullException("scheduler");
|
|
|
+ throw new ArgumentNullException(nameof(scheduler));
|
|
|
|
|
|
return s_impl.Timer(dueTime, scheduler);
|
|
|
}
|
|
|
@@ -1709,7 +1709,7 @@ namespace System.Reactive.Linq
|
|
|
public static IObservable<long> Timer(DateTimeOffset dueTime, IScheduler scheduler)
|
|
|
{
|
|
|
if (scheduler == null)
|
|
|
- throw new ArgumentNullException("scheduler");
|
|
|
+ throw new ArgumentNullException(nameof(scheduler));
|
|
|
|
|
|
return s_impl.Timer(dueTime, scheduler);
|
|
|
}
|
|
|
@@ -1726,9 +1726,9 @@ namespace System.Reactive.Linq
|
|
|
public static IObservable<long> Timer(TimeSpan dueTime, TimeSpan period, IScheduler scheduler)
|
|
|
{
|
|
|
if (period < TimeSpan.Zero)
|
|
|
- throw new ArgumentOutOfRangeException("period");
|
|
|
+ throw new ArgumentOutOfRangeException(nameof(period));
|
|
|
if (scheduler == null)
|
|
|
- throw new ArgumentNullException("scheduler");
|
|
|
+ throw new ArgumentNullException(nameof(scheduler));
|
|
|
|
|
|
return s_impl.Timer(dueTime, period, scheduler);
|
|
|
}
|
|
|
@@ -1745,9 +1745,9 @@ namespace System.Reactive.Linq
|
|
|
public static IObservable<long> Timer(DateTimeOffset dueTime, TimeSpan period, IScheduler scheduler)
|
|
|
{
|
|
|
if (period < TimeSpan.Zero)
|
|
|
- throw new ArgumentOutOfRangeException("period");
|
|
|
+ throw new ArgumentOutOfRangeException(nameof(period));
|
|
|
if (scheduler == null)
|
|
|
- throw new ArgumentNullException("scheduler");
|
|
|
+ throw new ArgumentNullException(nameof(scheduler));
|
|
|
|
|
|
return s_impl.Timer(dueTime, period, scheduler);
|
|
|
}
|
|
|
@@ -1766,7 +1766,7 @@ namespace System.Reactive.Linq
|
|
|
public static IObservable<Timestamped<TSource>> Timestamp<TSource>(this IObservable<TSource> source)
|
|
|
{
|
|
|
if (source == null)
|
|
|
- throw new ArgumentNullException("source");
|
|
|
+ throw new ArgumentNullException(nameof(source));
|
|
|
|
|
|
return s_impl.Timestamp<TSource>(source);
|
|
|
}
|
|
|
@@ -1782,9 +1782,9 @@ namespace System.Reactive.Linq
|
|
|
public static IObservable<Timestamped<TSource>> Timestamp<TSource>(this IObservable<TSource> source, IScheduler scheduler)
|
|
|
{
|
|
|
if (source == null)
|
|
|
- throw new ArgumentNullException("source");
|
|
|
+ throw new ArgumentNullException(nameof(source));
|
|
|
if (scheduler == null)
|
|
|
- throw new ArgumentNullException("scheduler");
|
|
|
+ throw new ArgumentNullException(nameof(scheduler));
|
|
|
|
|
|
return s_impl.Timestamp<TSource>(source, scheduler);
|
|
|
}
|
|
|
@@ -1812,9 +1812,9 @@ namespace System.Reactive.Linq
|
|
|
public static IObservable<IObservable<TSource>> Window<TSource>(this IObservable<TSource> source, TimeSpan timeSpan)
|
|
|
{
|
|
|
if (source == null)
|
|
|
- throw new ArgumentNullException("source");
|
|
|
+ throw new ArgumentNullException(nameof(source));
|
|
|
if (timeSpan < TimeSpan.Zero)
|
|
|
- throw new ArgumentOutOfRangeException("timeSpan");
|
|
|
+ throw new ArgumentOutOfRangeException(nameof(timeSpan));
|
|
|
|
|
|
return s_impl.Window<TSource>(source, timeSpan);
|
|
|
}
|
|
|
@@ -1837,11 +1837,11 @@ namespace System.Reactive.Linq
|
|
|
public static IObservable<IObservable<TSource>> Window<TSource>(this IObservable<TSource> source, TimeSpan timeSpan, IScheduler scheduler)
|
|
|
{
|
|
|
if (source == null)
|
|
|
- throw new ArgumentNullException("source");
|
|
|
+ throw new ArgumentNullException(nameof(source));
|
|
|
if (timeSpan < TimeSpan.Zero)
|
|
|
- throw new ArgumentOutOfRangeException("timeSpan");
|
|
|
+ throw new ArgumentOutOfRangeException(nameof(timeSpan));
|
|
|
if (scheduler == null)
|
|
|
- throw new ArgumentNullException("scheduler");
|
|
|
+ throw new ArgumentNullException(nameof(scheduler));
|
|
|
|
|
|
return s_impl.Window<TSource>(source, timeSpan, scheduler);
|
|
|
}
|
|
|
@@ -1871,11 +1871,11 @@ namespace System.Reactive.Linq
|
|
|
public static IObservable<IObservable<TSource>> Window<TSource>(this IObservable<TSource> source, TimeSpan timeSpan, TimeSpan timeShift)
|
|
|
{
|
|
|
if (source == null)
|
|
|
- throw new ArgumentNullException("source");
|
|
|
+ throw new ArgumentNullException(nameof(source));
|
|
|
if (timeSpan < TimeSpan.Zero)
|
|
|
- throw new ArgumentOutOfRangeException("timeSpan");
|
|
|
+ throw new ArgumentOutOfRangeException(nameof(timeSpan));
|
|
|
if (timeShift < TimeSpan.Zero)
|
|
|
- throw new ArgumentOutOfRangeException("timeShift");
|
|
|
+ throw new ArgumentOutOfRangeException(nameof(timeShift));
|
|
|
|
|
|
return s_impl.Window<TSource>(source, timeSpan, timeShift);
|
|
|
}
|
|
|
@@ -1906,13 +1906,13 @@ namespace System.Reactive.Linq
|
|
|
public static IObservable<IObservable<TSource>> Window<TSource>(this IObservable<TSource> source, TimeSpan timeSpan, TimeSpan timeShift, IScheduler scheduler)
|
|
|
{
|
|
|
if (source == null)
|
|
|
- throw new ArgumentNullException("source");
|
|
|
+ throw new ArgumentNullException(nameof(source));
|
|
|
if (timeSpan < TimeSpan.Zero)
|
|
|
- throw new ArgumentOutOfRangeException("timeSpan");
|
|
|
+ throw new ArgumentOutOfRangeException(nameof(timeSpan));
|
|
|
if (timeShift < TimeSpan.Zero)
|
|
|
- throw new ArgumentOutOfRangeException("timeShift");
|
|
|
+ throw new ArgumentOutOfRangeException(nameof(timeShift));
|
|
|
if (scheduler == null)
|
|
|
- throw new ArgumentNullException("scheduler");
|
|
|
+ throw new ArgumentNullException(nameof(scheduler));
|
|
|
|
|
|
return s_impl.Window<TSource>(source, timeSpan, timeShift, scheduler);
|
|
|
}
|
|
|
@@ -1940,11 +1940,11 @@ namespace System.Reactive.Linq
|
|
|
public static IObservable<IObservable<TSource>> Window<TSource>(this IObservable<TSource> source, TimeSpan timeSpan, int count)
|
|
|
{
|
|
|
if (source == null)
|
|
|
- throw new ArgumentNullException("source");
|
|
|
+ throw new ArgumentNullException(nameof(source));
|
|
|
if (timeSpan < TimeSpan.Zero)
|
|
|
- throw new ArgumentOutOfRangeException("timeSpan");
|
|
|
+ throw new ArgumentOutOfRangeException(nameof(timeSpan));
|
|
|
if (count <= 0)
|
|
|
- throw new ArgumentOutOfRangeException("count");
|
|
|
+ throw new ArgumentOutOfRangeException(nameof(count));
|
|
|
|
|
|
return s_impl.Window<TSource>(source, timeSpan, count);
|
|
|
}
|
|
|
@@ -1969,13 +1969,13 @@ namespace System.Reactive.Linq
|
|
|
public static IObservable<IObservable<TSource>> Window<TSource>(this IObservable<TSource> source, TimeSpan timeSpan, int count, IScheduler scheduler)
|
|
|
{
|
|
|
if (source == null)
|
|
|
- throw new ArgumentNullException("source");
|
|
|
+ throw new ArgumentNullException(nameof(source));
|
|
|
if (timeSpan < TimeSpan.Zero)
|
|
|
- throw new ArgumentOutOfRangeException("timeSpan");
|
|
|
+ throw new ArgumentOutOfRangeException(nameof(timeSpan));
|
|
|
if (count <= 0)
|
|
|
- throw new ArgumentOutOfRangeException("count");
|
|
|
+ throw new ArgumentOutOfRangeException(nameof(count));
|
|
|
if (scheduler == null)
|
|
|
- throw new ArgumentNullException("scheduler");
|
|
|
+ throw new ArgumentNullException(nameof(scheduler));
|
|
|
|
|
|
return s_impl.Window<TSource>(source, timeSpan, count, scheduler);
|
|
|
}
|