我有一个HttpMessage,它在某个时候需要一个结果。我希望用户能够等待一个任务,该任务在设置响应后或超时后返回乙醚。当运行我的单元测试时,它可以工作,但前提是我设置的超时时间比响应的延迟设置早得多。
为什么会发生这种情况,我能做些什么来缩短时间吗。
*请注意,下面的单元测试是有效的,但如果将延迟设置为500ms,则失败
HttpMessage代码:
public async Task<bool> ContinueWhenResponseRecieved(int Timeout)
{
NotifyTaskCompletionSource = new TaskCompletionSource<bool>();
bool result = true;
//If we have already recieved a response return true;
if (this._response != null)
{
return result;
}
//If Timeout is not 0 then start a task that after the timeout period will set the completion source to true no matter what
if (Timeout != 0)
{
TaskEx.Run(async () =>
{
await TaskEx.Delay(Timeout);
result = false;
try
{
NotifyTaskCompletionSource.SetResult(true);
}
catch (Exception ex) { } //ignore race condition issues
});
}
await NotifyTaskCompletionSource.Task;
return result;
}
public override IHttpMessage setResponse(HttpResponse _response)
{
if (NotifyTaskCompletionSource != null)
{
try
{
NotifyTaskCompletionSource.SetResult(true);
}catch(Exception ex){} //Ignore race condtion issues
}
return base.setResponse(_response);
}
单元测试:
[TestMethod]
public async Task TestNotifiableTimeOuts()
{
var msg = new NotifiableHttpMessage();
TaskEx.Run(() =>
{
TaskEx.Delay(1000).Wait();
msg.setResponse(new Messages.HttpResponse());
});
var result= await msg.ContinueWhenResponseRecieved(50);
Assert.IsFalse(result);
}
信用服务
问题是单元测试不是异步的,并且导致了问题。一个完全清除的异步测试完成了任务。最终结果单元测试:
[TestMethod]
public async Task TestNotifiableTimeOuts()
{
var msg = new NotifiableHttpMessage();
TaskEx.Run(async () =>
{
await TaskEx.Delay(200);
msg.setResponse(new Messages.HttpResponse());
});
var result= await msg.ContinueWhenResponseRecieved(50);
Assert.IsFalse(result);
}