another way around. Fix typo in comment.

This commit is contained in:
Boris-Barboris 2018-03-30 09:42:22 +00:00
parent 489b35539b
commit bf9d736c4f

View file

@ -743,8 +743,8 @@ struct LocalManualEvent {
*/ */
int wait() { return wait(this.emitCount); } int wait() { return wait(this.emitCount); }
/** Acquires ownership and waits until the emit count differs from the /** Acquires ownership and waits until the signal is emitted and the emit
given one or until a timeout is reached. count is larger than a given one.
Throws: Throws:
May throw an $(D InterruptException) if the task gets interrupted May throw an $(D InterruptException) if the task gets interrupted
@ -778,7 +778,7 @@ struct LocalManualEvent {
target_timeout = now + timeout; target_timeout = now + timeout;
} }
while (m_waiter.m_emitCount - emit_count >= 0) { while (m_waiter.m_emitCount - emit_count <= 0) {
m_waiter.wait!interruptible(timeout != Duration.max ? target_timeout - now : Duration.max); m_waiter.wait!interruptible(timeout != Duration.max ? target_timeout - now : Duration.max);
try now = Clock.currTime(UTC()); try now = Clock.currTime(UTC());
catch (Exception e) { assert(false, e.msg); } catch (Exception e) { assert(false, e.msg); }