module Streaming.Binary (decode, decodeWith, decoded, decodedWith) where
import qualified Data.Binary.Get as Binary
import Data.Binary (Binary(..))
import qualified Data.ByteString.Streaming as Q
import Data.ByteString.Streaming (ByteString)
import Data.Int (Int64)
import Streaming
import qualified Streaming.Prelude as S
decode
:: (Binary a, Monad m)
=> ByteString m r
-> m (ByteString m r, Int64, Either String a)
decode = decodeWith get
decodeWith
:: Monad m
=> Binary.Get a
-> ByteString m r
-> m (ByteString m r, Int64, Either String a)
decodeWith getter = go 0 (Binary.runGetIncremental getter)
where
go !total (Binary.Fail leftover nconsumed err) p = do
return (Q.chunk leftover >> p, total + nconsumed, Left err)
go !total (Binary.Done leftover nconsumed x) p = do
return (Q.chunk leftover >> p, total + nconsumed, Right x)
go !total (Binary.Partial k) p = do
Q.nextChunk p >>= \case
Left res -> go total (k Nothing) (return res)
Right (bs, p') -> go total (k (Just bs)) p'
decoded
:: (Binary a, Monad m)
=> ByteString m r
-> Stream (Of a) m (ByteString m r, Int64, Either String r)
decoded = decodedWith get
decodedWith
:: Monad m
=> Binary.Get a
-> ByteString m r
-> Stream (Of a) m (ByteString m r, Int64, Either String r)
decodedWith getter = go 0 decoder0
where
decoder0 = Binary.runGetIncremental getter
go !total (Binary.Fail leftover nconsumed err) p = do
return (Q.chunk leftover >> p, total + nconsumed, Left err)
go !total (Binary.Done "" nconsumed x) p = do
S.yield x
lift (Q.nextChunk p) >>= \case
Left res -> return (return res, total + nconsumed, Right res)
Right (bs, p') -> do
go (total + nconsumed) decoder0 (Q.chunk bs >> p')
go !total (Binary.Done leftover nconsumed x) p = do
S.yield x
go (total + nconsumed) (decoder0 `Binary.pushChunk` leftover) p
go !total (Binary.Partial k) p = do
lift (Q.nextChunk p) >>= \case
Left res -> go total (k Nothing) (return res)
Right (bs, p') -> go total (k (Just bs)) p'