vibe-core/tests/issue-157-consume-closed-channel.d
2019-06-16 23:00:04 +02:00

30 lines
398 B
D

/+ dub.sdl:
name "tests"
dependency "vibe-core" path=".."
+/
module tests;
import vibe.core.channel;
import vibe.core.core;
import core.time;
void main()
{
auto ch = createChannel!int();
auto p = runTask({
sleep(1.seconds);
ch.close();
});
auto c = runTask({
while (!ch.empty) {
try ch.consumeOne();
catch (Exception e) assert(false, e.msg);
}
});
p.join();
c.join();
}