Amping up the redis client library in haskell.

inredis.hs

subscriptionEnumerator :: (BS s, MonadIO m) =>
                          Redis 
                       -> Int
                       -> Enumerator (Message s) m b
subscriptionEnumerator rs timeout (Continue k) = do
  nextRead <- liftIO $ listen rs timeout;
  let chunk = Chunks $ maybeToList nextRead in
    k chunk >>== subscriptionEnumerator rs timeout
subscriptionEnumerator rs timeout step = returnI step