0-pipes.hs

listContainers :: HTTP.Manager -> AccountName -> P.Producer ByteString IO ()
listContainers manager account = do
        req <- P.lift $ fillOutTemplate template -- does some IO to fill out the request
        let req' = Auth.signRequest account req
        join $ P.lift $ HTTP.withHTTP req' manager $ \resp ->
            return (P.for (HTTP.responseBody resp) P.yield)

1-my-pipes-http.hs

module Azure.Storage.Protocol.HttpHelpers
    ( httpRequest
    ) where

import           Control.Monad (unless)
import qualified Data.ByteString as BS
import           Network.HTTP.Client
import           Pipes
import           Pipes.Safe

httpRequest :: (MonadSafe m, MonadIO m) => Request -> Manager -> Producer BS.ByteString m ()
httpRequest r m =
    bracket
        (liftIO $ responseOpen r m)
        (liftIO . responseClose)
        (produce . responseBody)
    where
        produce body = loop
            where
            loop = do
                chunk <- lift $ liftIO $ brRead body
                unless (BS.null chunk) $
                    yield chunk >> loop

2-pipes2.hs

listContainers :: (MonadSafe m, MonadIO m) => HTTP.Manager -> AccountName -> Producer ContainerName m ()
listContainers manager account = do
        req <- lift $ liftIO $ fillOutTemplate template
        let signedReq = Auth.signRequest account req
        sax (httpRequest signedReq manager) >-> elementContent "Name" >-> P.map ContainerName