Support streamly-core-0.3.0

src/Streamly/External/ByteString.hs

@@ -101,6 +101,13 @@ pinnedCreate = Array.pinnedWrite
 ensurePinned = pure
 pinnedCreateOf = Array.writeN
 pinnedCreate = Array.write
+array_createN = Array.writeN
+#endif
+
+#if MIN_VERSION_streamly_core(0,3,0)
+#define CREATE_N Array.createOf
+#else
+#define CREATE_N Array.writeN
 #endif
 
 {-# INLINE mutableByteArrayContents# #-}
@@ -129,7 +136,7 @@ toArray (CONSTRUCTOR((ForeignPtr addr# (PlainPtr marr#)), off0, len)) =
 toArray (CONSTRUCTOR(fptr, off, len)) =
     unsafeInlineIO
         $ withForeignPtr (fptr WHEN_0_10_12(`plusForeignPtr` off))
-        $ Unfold.fold (Array.writeN len) generator
+        $ Unfold.fold (CREATE_N len) generator
 
     where
 

src/Streamly/External/ByteString/Lazy.hs

@@ -37,6 +37,12 @@ import qualified Streamly.Data.Stream as Stream
 
 import Prelude hiding (read)
 
+#if MIN_VERSION_streamly_core(0,3,0)
+#define UNFOLD_EACH Unfold.unfoldEach
+#else
+#define UNFOLD_EACH Unfold.many
+#endif
+
 -- | Unfold a lazy ByteString to a stream of 'Array' 'Words'.
 {-# INLINE  chunkReader #-}
 chunkReader :: Monad m => Unfold m ByteString (Array Word8)
@@ -49,7 +55,7 @@ chunkReader = Unfold step seed
 -- | Unfold a lazy ByteString to a stream of Word8
 {-# INLINE reader #-}
 reader :: Monad m => Unfold m ByteString Word8
-reader = Unfold.many Array.reader readChunks
+reader = UNFOLD_EACH Array.reader readChunks
 
 -- TODO: "toChunks" should be called "read" instead
 -- | Convert a lazy 'ByteString' to a serial stream of 'Array' 'Word8'.

streamly-bytestring.cabal

@@ -48,7 +48,7 @@ library
                  || == 0.11.4.*
                  || == 0.11.5.*
                  || == 0.12.0.*
-    , streamly-core >= 0.1.0 && < 0.2.3
+    , streamly-core >= 0.1.0 && < 0.3.1
   default-language: Haskell2010
 
 test-suite sb-test