Hello,
I am trying to adapt streaming version of `zstandard
<https://hackage.haskell.org/package/zstd-0.1.0.0/docs/Codec-Compression-Zstd-Streaming.html>`
using `Streaming` library. There is already a version
<https://github.com/michaelt/streaming-zstd/blob/master/Streaming/Zstd.hs>
that exists using `ByteString m r`. I can't figure out how to implement a
function like below, and will appreciate help:
stream :: MonadIO m => S.Stream (S.Of B.ByteString) m r -> Result -> S.
Stream (S.Of B.ByteString) m r
Here is the original code from `streaming-zstd`:
stream :: MonadIO m => ByteString m r -> Result -> ByteString m r
stream (Go m) res = lift m >>= flip stream res
stream bs (Error who what) = error (who ++ ": " ++ what)
stream bs (Produce bytes res') = Chunk bytes (liftIO res' >>= stream bs)
stream (Chunk c cs) (Consume f) = liftIO (f c) >>= stream cs
stream (Empty r) (Consume f) = liftIO (f mempty) >>= stream (Empty r)
stream (Empty r) (Done o) = Chunk o (Empty r)
stream input state = error $ "unpossible! bytes of input left in stream
state "
++ show state
--
You received this message because you are subscribed to the Google Groups
"Haskell Pipes" group.
To unsubscribe from this group and stop receiving emails from it, send an email
to haskell-pipes+unsubscr...@googlegroups.com.
To post to this group, send email to haskell-pipes@googlegroups.com.
