diff options
Diffstat (limited to 'Rx.NET/Tests.System.Reactive/Extensions.cs')
-rw-r--r-- | Rx.NET/Tests.System.Reactive/Extensions.cs | 39 |
1 files changed, 0 insertions, 39 deletions
diff --git a/Rx.NET/Tests.System.Reactive/Extensions.cs b/Rx.NET/Tests.System.Reactive/Extensions.cs deleted file mode 100644 index 9ed942b..0000000 --- a/Rx.NET/Tests.System.Reactive/Extensions.cs +++ /dev/null @@ -1,39 +0,0 @@ -// Copyright (c) Microsoft Open Technologies, Inc. All rights reserved. See License.txt in the project root for license information. - -using System; -using System.Collections.Generic; -using System.Reactive.Concurrency; -using System.Reactive.Disposables; -using Microsoft.Reactive.Testing; - -namespace ReactiveTests -{ - public static class Extensions - { - //public static IDisposable ScheduleAbsolute(this TestScheduler scheduler, long time, Action action) - //{ - // return scheduler.ScheduleAbsolute(default(object), time, (scheduler1, state1) => { action(); return Disposable.Empty; }); - //} - - //public static IDisposable ScheduleRelative(this TestScheduler scheduler, long time, Action action) - //{ - // return scheduler.ScheduleRelative(default(object), time, (scheduler1, state1) => { action(); return Disposable.Empty; }); - //} - - public static void EnsureTrampoline(this CurrentThreadScheduler scheduler, Action action) - { - if (scheduler.ScheduleRequired) - scheduler.Schedule(action); - else - action(); - } - - public static IEnumerable<R> Zip<T1, T2, R>(this IEnumerable<T1> source1, IEnumerable<T2> source2, Func<T1, T2, R> f) - { - using (var e1 = source1.GetEnumerator()) - using (var e2 = source2.GetEnumerator()) - while (e1.MoveNext() && e2.MoveNext()) - yield return f(e1.Current, e2.Current); - } - } -} |