store-streaming 0.1.0.0 → 0.2.0.0
raw patch · 3 files changed
+14/−6 lines, 3 filesPVP ok
version bump matches the API change (PVP)
API changes (from Hackage documentation)
- Data.Store.Streaming: decodeMessageFd :: (MonadIO m, Store a) => ByteBuffer -> Fd -> m (Message a)
+ Data.Store.Streaming: decodeMessageFd :: (MonadIO m, MonadFail m, Store a) => ByteBuffer -> Fd -> m (Message a)
- Data.Store.Streaming: peekMessageFd :: (MonadIO m, Store a) => ByteBuffer -> Fd -> PeekMessage ReadMoreData m (Message a)
+ Data.Store.Streaming: peekMessageFd :: (MonadIO m, MonadFail m, Store a) => ByteBuffer -> Fd -> PeekMessage ReadMoreData m (Message a)
Files
- ChangeLog.md +6/−0
- src/Data/Store/Streaming.hs +3/−2
- store-streaming.cabal +5/−4
ChangeLog.md view
@@ -1,5 +1,11 @@ # ChangeLog +## 0.2.0.0++* Now builds with GHC-8.8. This is a major version bump because+ MonadFail constraints were added to some functions, which is+ potentially a breaking change.+ ## 0.1.0.0 * `Data.Store.Streaming` forked from `store-0.4.3.2`
src/Data/Store/Streaming.hs view
@@ -44,6 +44,7 @@ import Control.Exception (throwIO) import Control.Monad (unless)+import Control.Monad.Fail (MonadFail) import Control.Monad.IO.Class import Control.Monad.Trans.Resource (MonadResource) import Data.ByteString (ByteString)@@ -180,7 +181,7 @@ -- | Peeks a message from a _non blocking_ 'Fd'. -- -- This function is only available on POSIX systems (essentially, non-windows)-peekMessageFd :: (MonadIO m, Store a) => ByteBuffer -> Fd -> PeekMessage ReadMoreData m (Message a)+peekMessageFd :: (MonadIO m, MonadFail m, Store a) => ByteBuffer -> Fd -> PeekMessage ReadMoreData m (Message a) peekMessageFd bb fd = peekMessage (\bb_ needed ReadMoreData -> do _ <- BB.fillFromFd bb_ fd needed; return ()) bb @@ -188,7 +189,7 @@ -- ready for reading. -- -- This function is only available on POSIX systems (essentially, non-windows)-decodeMessageFd :: (MonadIO m, Store a) => ByteBuffer -> Fd -> m (Message a)+decodeMessageFd :: (MonadIO m, MonadFail m, Store a) => ByteBuffer -> Fd -> m (Message a) decodeMessageFd bb fd = do mbMsg <- decodeMessage (\bb_ needed ReadMoreData -> do _ <- BB.fillFromFd bb_ fd needed; return ()) bb
store-streaming.cabal view
@@ -1,11 +1,13 @@--- This file has been generated from package.yaml by hpack version 0.28.2.+cabal-version: 1.12++-- This file has been generated from package.yaml by hpack version 0.31.1. -- -- see: https://github.com/sol/hpack ----- hash: b0f16693a79e5a6c8fc78c811d1173f5f53f4f2be86cbadb0b4712cacbca61b9+-- hash: 797c4f56ae9593d8831121a4ae75b30d1b9dfb4c43f4af5ec03a2563766e5638 name: store-streaming-version: 0.1.0.0+version: 0.2.0.0 synopsis: Streaming interfaces for `store` category: Serialization, Data homepage: https://github.com/fpco/store#readme@@ -15,7 +17,6 @@ license: MIT license-file: LICENSE build-type: Simple-cabal-version: >= 1.10 extra-source-files: ChangeLog.md