Skip to content

Commit 5a3a6dd

Browse files
committed
Remove DelayedSwitchTo.
1 parent ef549ba commit 5a3a6dd

File tree

3 files changed

+0
-108
lines changed

3 files changed

+0
-108
lines changed

src/AsyncFiberWorks/Fibers/FiberSwitcher.cs

Lines changed: 0 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -9,25 +9,12 @@ public static class FiberSwitcher
99
{
1010
/// <summary>
1111
/// Switch the current context to the specified one.
12-
/// It is also a flush function that waits for all queued actions to be executed.
1312
/// </summary>
1413
/// <param name="fiber">The context to switch to.</param>
1514
/// <returns></returns>
1615
public static FiberNotifyCompletion SwitchTo(this IExecutionContext fiber)
1716
{
1817
return new FiberNotifyCompletion(fiber);
1918
}
20-
/// <summary>
21-
/// Switch the current context to the specified one.
22-
/// It is also a flush function that waits for all queued actions to be executed.
23-
/// </summary>
24-
/// <param name="fiber">The context to switch to.</param>
25-
/// <param name="milliseconds">Waiting time. In milliseconds.</param>
26-
/// <param name="timer">Timer used to wait for time.</param>
27-
/// <returns></returns>
28-
public static FiberTimerNotifyCompletion DelayedSwitchTo(this IExecutionContext fiber, int milliseconds, IOneshotTimer timer)
29-
{
30-
return new FiberTimerNotifyCompletion(fiber, milliseconds, timer);
31-
}
3219
}
3320
}

src/AsyncFiberWorks/Fibers/FiberTimerNotifyCompletion.cs

Lines changed: 0 additions & 59 deletions
This file was deleted.

src/AsyncFiberWorksTests/TimerActionTests.cs

Lines changed: 0 additions & 36 deletions
Original file line numberDiff line numberDiff line change
@@ -116,42 +116,6 @@ public async Task OneshotTimerDelayTest(Func<IOneshotTimer> timerCreator)
116116
timer.Dispose();
117117
}
118118

119-
[Test, TestCaseSource(nameof(OneshotTimers))]
120-
public async Task DelayedSwitchToTest(Func<IOneshotTimer> timerCreator)
121-
{
122-
var timer = timerCreator();
123-
var fiber = new PoolFiber();
124-
var sw = new Stopwatch();
125-
int tolerance = 32;
126-
127-
// warm up.
128-
sw.Restart();
129-
await fiber.DelayedSwitchTo(1, timer);
130-
131-
int expectedWaitTime = 300;
132-
sw.Restart();
133-
await fiber.DelayedSwitchTo(expectedWaitTime, timer);
134-
var elapsed = sw.Elapsed;
135-
Assert.IsTrue(elapsed.TotalMilliseconds > (expectedWaitTime - tolerance ));
136-
Assert.IsTrue(elapsed.TotalMilliseconds < (expectedWaitTime + tolerance ), $"elapsedMs={elapsed.TotalMilliseconds}");
137-
138-
expectedWaitTime = 200;
139-
sw.Restart();
140-
await fiber.DelayedSwitchTo(expectedWaitTime, timer);
141-
elapsed = sw.Elapsed;
142-
Assert.IsTrue(elapsed.TotalMilliseconds > (expectedWaitTime - tolerance ));
143-
Assert.IsTrue(elapsed.TotalMilliseconds < (expectedWaitTime + tolerance ));
144-
145-
expectedWaitTime = 100;
146-
sw.Restart();
147-
await fiber.DelayedSwitchTo(expectedWaitTime, timer);
148-
elapsed = sw.Elapsed;
149-
Assert.IsTrue(elapsed.TotalMilliseconds > (expectedWaitTime - tolerance ));
150-
Assert.IsTrue(elapsed.TotalMilliseconds < (expectedWaitTime + tolerance ));
151-
152-
timer.Dispose();
153-
}
154-
155119
static object[] OneshotTimers =
156120
{
157121
new object[] { (Func<IOneshotTimer>)(() => new OneshotThreadingTimer()) },

0 commit comments

Comments
 (0)