From 0c8c1af630645126023f22d38ee8c6dac29016d2 Mon Sep 17 00:00:00 2001 From: jmdavis Date: Fri, 18 Feb 2011 20:26:43 -0800 Subject: [PATCH] Added version of receiveTimout which takes a Duration. --- std/concurrency.d | 10 ++++++++++ 1 file changed, 10 insertions(+) diff --git a/std/concurrency.d b/std/concurrency.d index 620e254bd1d..d6ca6c19fca 100644 --- a/std/concurrency.d +++ b/std/concurrency.d @@ -501,6 +501,11 @@ bool receiveTimeout(T...)( long ms, T ops ) return mbox.get( ms * TICKS_PER_MILLI, ops ); } +/++ ditto +/ +bool receiveTimeout(T...)( Duration duration, T ops ) +{ + return receiveTimeout(duration.total!"msecs"(), ops); +} unittest { @@ -519,6 +524,11 @@ unittest { receiveTimeout( 0, (int x) {}, (int x) {} ); } ) ); + + assert( __traits( compiles, + { + receiveTimeout( dur!"msecs"(10), (int x) {}, (Variant x) {} ); + } ) ); }