Объединить каналы в один

Я ищу функцию, которая может сделать что-то похожее на:

merge :: MonadIO m => [Producer m a] -> Producer m a

Я бегло взглянул на stm-conduit, он выглядит похоже, но я не уверен, что он соответствует моим требованиям:

messagesSource :: MonadIO m => AmqpConn -> Ack -> Text -> Producer m (Message, Envelope)
messagesSource conn ack q = loop
  where
    loop = do
      mmsg <- liftIO $ getMsg chan ack q
      case mmsg of
        Just (m, e) -> do
          yield (m, e)
          liftIO $ ackMsg chan (envDeliveryTag e) False
          loop
        Nothing     -> loop
    chan = fst $ amqpChan conn

Как видите, этот производитель каналов подтверждает сообщение после его передачи. В простом «однопоточном» конвейере это работает хорошо, сообщение попадает в приемник, а затем подтверждается.

Однако с stm-conduit это может измениться, потому что, насколько я понимаю, производитель не будет ждать, пока сообщение будет использовано приемником, вместо этого они будут работать параллельно, и сообщение может быть подтверждено преждевременно.

Правильно ли я понимаю stm-conduit?
И как можно объединить отдельные источники в один, чтобы получить хорошую семантику одного потока?

ОБНОВЛЕНИЕ: код обновлен до реального рабочего примера AMQP в соответствии с запросом (однако он может быть немного более шумным).

ОБНОВЛЕНИЕ 2: я думаю, что то, что мне нужно, может быть альтернативным экземпляром для источников каналов, поэтому я мог бы сделать что-то вроде let src = src1 <|> src2. Можно как-нибудь?