bolty-streamly 0.1.0.0 → 0.1.0.1
raw patch · 2 files changed
+9/−7 lines, 2 filesdep ~boltyPVP ok
version bump matches the API change (PVP)
Dependency ranges changed: bolty
API changes (from Hackage documentation)
Files
bolty-streamly.cabal view
@@ -5,7 +5,7 @@ -- see: https://github.com/sol/hpack name: bolty-streamly-version: 0.1.0.0+version: 0.1.0.1 synopsis: Streamly streaming interface for bolty Neo4j driver description: Streaming queries over Neo4j using streamly streams. Wraps bolty's query functions with streamly's Stream type for@@ -65,7 +65,7 @@ ghc-options: -Weverything -Wno-all-missed-specialisations -Wno-implicit-prelude -Wno-missed-specialisations -Wno-missing-import-lists -Wno-missing-safe-haskell-mode -Wno-name-shadowing -Wno-prepositive-qualified-module -Wno-safe -Wno-unsafe build-depends: base >=4.18 && <5- , bolty >=0.1.0.2 && <0.2+ , bolty >=0.1.1.0 && <0.2 , packstream-bolt ==0.1.* , streamly-core ==0.2.* , text >=2.0 && <2.2@@ -106,7 +106,7 @@ ghc-options: -Weverything -Wno-all-missed-specialisations -Wno-implicit-prelude -Wno-missed-specialisations -Wno-missing-import-lists -Wno-missing-safe-haskell-mode -Wno-name-shadowing -Wno-prepositive-qualified-module -Wno-safe -Wno-unsafe -threaded -rtsopts -with-rtsopts=-N -Wno-missing-export-lists -Wno-missing-local-signatures -Wno-monomorphism-restriction -Wno-unused-imports -Wno-unused-packages build-depends: base >=4.18 && <5- , bolty >=0.1.0.2 && <0.2+ , bolty >=0.1.1.0 && <0.2 , bolty-streamly , data-default , packstream-bolt ==0.1.*@@ -151,7 +151,7 @@ ghc-options: -Weverything -Wno-all-missed-specialisations -Wno-implicit-prelude -Wno-missed-specialisations -Wno-missing-import-lists -Wno-missing-safe-haskell-mode -Wno-name-shadowing -Wno-prepositive-qualified-module -Wno-safe -Wno-unsafe -threaded -rtsopts -with-rtsopts=-N -Wno-missing-export-lists -Wno-missing-local-signatures -Wno-monomorphism-restriction -Wno-unused-imports -Wno-unused-packages build-depends: base >=4.18 && <5- , bolty >=0.1.0.2 && <0.2+ , bolty >=0.1.1.0 && <0.2 , bolty-streamly , packstream-bolt ==0.1.* , sandwich
src/Database/Bolty/Streamly.hs view
@@ -69,7 +69,7 @@ import qualified Database.Bolty.Connection.Pipe as P import Database.Bolty.Connection.Type import Database.Bolty.Decode (RowDecoder, decodeRow)-import Database.Bolty.Message.Request (Request(..), defaultPull, Begin(Begin), TelemetryApi(..))+import Database.Bolty.Message.Request (Request(..), Pull(..), Begin(Begin), TelemetryApi(..)) import Database.Bolty.Message.Response (Response(..), Failure(..), successFields) import Database.Bolty.Pool (BoltPool, CheckedOutConnection(..), acquireConnection, releaseConnection,@@ -144,7 +144,8 @@ pullStream :: HasCallStack => Connection -> IO (Stream IO Record) pullStream conn = do P.requireStateIO conn [Streaming, TXstreaming] "PULL"- P.flushIO conn $ RPull defaultPull+ let pull = Pull { n = conn.fetchSize, qid = Nothing }+ P.flushIO conn $ RPull pull pure $ Stream.unfoldrM (step conn) NeedPull where step :: HasCallStack => Connection -> PullState -> IO (Maybe (Record, PullState))@@ -162,7 +163,8 @@ _ -> False Nothing -> False if hasMore then do- P.flushIO c $ RPull defaultPull+ let pull = Pull { n = c.fetchSize, qid = Nothing }+ P.flushIO c $ RPull pull step c NeedPull else do st <- P.getState c