|
@@ -20,6 +20,8 @@ namespace ReactiveTests.Tests
|
|
|
|
|
|
public class EventLoopSchedulerTest
|
|
|
{
|
|
|
+ private static readonly TimeSpan MaxWaitTime = TimeSpan.FromSeconds(5);
|
|
|
+
|
|
|
[Fact]
|
|
|
public void EventLoop_ArgumentChecking()
|
|
|
{
|
|
@@ -66,7 +68,7 @@ namespace ReactiveTests.Tests
|
|
|
ran = true;
|
|
|
gate.Release();
|
|
|
});
|
|
|
- Assert.True(gate.WaitOne(TimeSpan.FromSeconds(2)));
|
|
|
+ Assert.True(gate.WaitOne(MaxWaitTime));
|
|
|
Assert.True(ran);
|
|
|
}
|
|
|
|
|
@@ -82,7 +84,7 @@ namespace ReactiveTests.Tests
|
|
|
id = Thread.CurrentThread.ManagedThreadId;
|
|
|
gate.Release();
|
|
|
});
|
|
|
- Assert.True(gate.WaitOne(TimeSpan.FromSeconds(2)));
|
|
|
+ Assert.True(gate.WaitOne(MaxWaitTime));
|
|
|
Assert.NotEqual(Thread.CurrentThread.ManagedThreadId, id);
|
|
|
}
|
|
|
#endif
|
|
@@ -99,7 +101,7 @@ namespace ReactiveTests.Tests
|
|
|
results.Add(1);
|
|
|
gate.Release();
|
|
|
});
|
|
|
- Assert.True(gate.WaitOne(TimeSpan.FromSeconds(2)));
|
|
|
+ Assert.True(gate.WaitOne(MaxWaitTime));
|
|
|
results.AssertEqual(0, 1);
|
|
|
}
|
|
|
|
|
@@ -165,7 +167,7 @@ namespace ReactiveTests.Tests
|
|
|
gate.Release();
|
|
|
});
|
|
|
|
|
|
- Assert.True(gate.WaitOne(TimeSpan.FromSeconds(2)));
|
|
|
+ Assert.True(gate.WaitOne(MaxWaitTime));
|
|
|
results.AssertEqual(1, 0);
|
|
|
}
|
|
|
|
|
@@ -182,7 +184,7 @@ namespace ReactiveTests.Tests
|
|
|
gate.Release();
|
|
|
});
|
|
|
|
|
|
- Assert.True(gate.WaitOne(TimeSpan.FromSeconds(2)));
|
|
|
+ Assert.True(gate.WaitOne(MaxWaitTime));
|
|
|
results.AssertEqual(1, 0);
|
|
|
}
|
|
|
|
|
@@ -204,7 +206,7 @@ namespace ReactiveTests.Tests
|
|
|
});
|
|
|
});
|
|
|
|
|
|
- Assert.True(gate.WaitOne(TimeSpan.FromSeconds(2)));
|
|
|
+ Assert.True(gate.WaitOne(MaxWaitTime));
|
|
|
results.AssertEqual(0, 1, 2);
|
|
|
}
|
|
|
|
|
@@ -227,7 +229,7 @@ namespace ReactiveTests.Tests
|
|
|
});
|
|
|
});
|
|
|
|
|
|
- Assert.True(gate.WaitOne(TimeSpan.FromSeconds(2)));
|
|
|
+ Assert.True(gate.WaitOne(MaxWaitTime));
|
|
|
results.AssertEqual(0, 4, 1, 2);
|
|
|
}
|
|
|
|
|
@@ -242,7 +244,7 @@ namespace ReactiveTests.Tests
|
|
|
ran = true;
|
|
|
gate.Release();
|
|
|
}));
|
|
|
- Assert.True(gate.WaitOne(TimeSpan.FromSeconds(2)));
|
|
|
+ Assert.True(gate.WaitOne(MaxWaitTime));
|
|
|
Assert.True(ran);
|
|
|
}
|
|
|
|
|
@@ -260,7 +262,7 @@ namespace ReactiveTests.Tests
|
|
|
sw.Stop();
|
|
|
gate.Release();
|
|
|
});
|
|
|
- Assert.True(gate.WaitOne(TimeSpan.FromSeconds(2)));
|
|
|
+ Assert.True(gate.WaitOne(MaxWaitTime));
|
|
|
Assert.True(ran, "ran");
|
|
|
Assert.True(sw.ElapsedMilliseconds > 180, "due " + sw.ElapsedMilliseconds);
|
|
|
}
|
|
@@ -286,7 +288,7 @@ namespace ReactiveTests.Tests
|
|
|
});
|
|
|
});
|
|
|
|
|
|
- Assert.True(gate.WaitOne(TimeSpan.FromSeconds(2)));
|
|
|
+ Assert.True(gate.WaitOne(MaxWaitTime));
|
|
|
Assert.True(ran, "ran");
|
|
|
Assert.True(sw.ElapsedMilliseconds > 380, "due " + sw.ElapsedMilliseconds);
|
|
|
}
|