Обожаю

asyncConsumerAction :: Consumer a -> Consumer (Async a)
asyncConsumerAction action = ask >>= liftIO . async . runConsumerM_ action