diff --git a/bolty-streamly.cabal b/bolty-streamly.cabal
--- a/bolty-streamly.cabal
+++ b/bolty-streamly.cabal
@@ -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
diff --git a/src/Database/Bolty/Streamly.hs b/src/Database/Bolty/Streamly.hs
--- a/src/Database/Bolty/Streamly.hs
+++ b/src/Database/Bolty/Streamly.hs
@@ -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