module Affection.MessageBus.Util where import Affection.MessageBus.Class import Affection.MessageBus.Message import Control.Concurrent.STM as STM newBroadcastChannel :: (Message msg) => IO (Channel msg) newBroadcastChannel = atomically $ Channel <$> newBroadcastTChan