Skip to content

Commit 47d4612

Browse files
author
Marc Piechura
authored
Merge pull request #36 from reactive-streams/check_for_negative_timeout
fail if timeout is reached
2 parents 5c27fee + 7b41db6 commit 47d4612

File tree

1 file changed

+3
-0
lines changed

1 file changed

+3
-0
lines changed

src/tck/Reactive.Streams.TCK/TestEnvironment.cs

+3
Original file line numberDiff line numberDiff line change
@@ -861,6 +861,9 @@ public List<T> NextN(long elements, long timeoutMilliseconds, string errorMessag
861861
{
862862
var remainingMilliseconds = (long)(deadline - DateTime.Now).TotalMilliseconds;
863863

864+
if (remainingMilliseconds < 0)
865+
return _environment.FlopAndFail<List<T>>($"{errorMessage} within {timeoutMilliseconds} ms");
866+
864867
result.Add(Next(remainingMilliseconds, errorMessage));
865868
remaining--;
866869
}

0 commit comments

Comments
 (0)