Fix/reimplement the broadcast class using vibe.core.concurrency.