curryer-rpc 0.3.5 → 0.3.6

raw patch · 4 files changed

+14/−19 lines, 4 filesdep ~streamlydep ~streamly-bytestringdep ~streamly-corePVP ok

version bump matches the API change (PVP)

Dependency ranges changed: streamly, streamly-bytestring, streamly-core

API changes (from Hackage documentation)

Files

Changelog.markdown +5/−0
curryer-rpc.cabal +5/−4
src/Network/RPC/Curryer/Server.hs +4/−10
src/Network/RPC/Curryer/StreamlyAdditions.hs +0/−5

Changelog.markdown view

@@ -1,3 +1,8 @@+# v0.3.6 (2024-07-20)++* update to streamly 0.10.1+* update to streamly-bytestring 0.2.2 which includes a critical fix related to pinned arrays used within streamly+ # v0.3.5 (2024-01-12)  * disable extraneous debug logging

curryer-rpc.cabal view

@@ -1,5 +1,5 @@ Name: curryer-rpc-Version: 0.3.5+Version: 0.3.6 License: PublicDomain Build-Type: Simple Homepage: https://github.com/agentm/curryer@@ -21,9 +21,10 @@         Build-Depends: base >= 4.12 && < 4.19                      , winery                      , bytestring-                     , streamly == 0.9.0-                     , streamly-core >= 0.1.0-                     , streamly-bytestring >= 0.2.0+                     , streamly == 0.10.1+                     , streamly-core >= 0.2.2+-- includes critical fix for pinned arrays+                     , streamly-bytestring >= 0.2.2                      , network                      , exceptions                      , async

src/Network/RPC/Curryer/Server.hs view

@@ -3,16 +3,8 @@ {- HLINT ignore "Use lambda-case" -} module Network.RPC.Curryer.Server where import qualified Streamly.Data.Stream.Prelude as SP-#if MIN_VERSION_streamly(0,9,0)-import Streamly.Internal.Data.Stream.Concurrent as Stream-import Streamly.Internal.Serialize.FromBytes (word32be)-import qualified Streamly.Internal.Data.Array.Type as Arr-#else-import qualified Streamly.Data.Array as Arr-import Streamly.Data.Stream.Prelude as Stream hiding (foldr)-import Streamly.Internal.Data.Binary.Parser (word32be)-#endif import Streamly.Data.Stream as Stream hiding (foldr)+import Streamly.Internal.Data.Array (pinnedCreateOf)  import Streamly.Network.Socket as SSock import Network.Socket as Socket@@ -34,6 +26,8 @@ --import qualified Streamly.Internal.Data.Stream.IsStream as P import qualified Streamly.Data.Stream.Prelude as P import qualified Streamly.External.ByteString as StreamlyBS+import Streamly.Data.Stream.Prelude as Stream hiding (foldr)+import Streamly.Internal.Data.Binary.Parser (word32be) import qualified Data.Binary as B import qualified Data.UUID as UUIDBase import qualified Data.UUID.V4 as UUIDBase@@ -201,7 +195,7 @@         if c == 0 then           pure mempty           else do-          ps <- P.takeEQ c (Arr.writeN c)+          ps <- P.takeEQ c (pinnedCreateOf c) --          traceShowM ("envelopeP read bytes", c)           let !bs = StreamlyBS.fromArray ps --          traceShowM ("unoptimized bs")

src/Network/RPC/Curryer/StreamlyAdditions.hs view

@@ -8,13 +8,8 @@ import Data.Word import qualified Streamly.Internal.Data.Unfold as UF import Streamly.Network.Socket hiding (acceptor)-#if MIN_VERSION_streamly(0,9,0)-import qualified Streamly.Internal.Data.Stream.StreamD as D-import Streamly.Internal.Data.Unfold.Type (Unfold(..))-#else import qualified Streamly.Internal.Data.Stream as D import Streamly.Internal.Data.Unfold (Unfold(..))-#endif  acceptorOnAddr     :: MonadIO m