@@ -101,7 +101,7 @@ import Foreign.Marshal.Alloc (alloca, allocaBytes)
101101import Foreign.Storable (peekByteOff)
102102import Foreign.Ptr (Ptr, FunPtr, castPtr, nullPtr, nullFunPtr, plusPtr)
103103import Streamly.Internal.Data.Stream (Stream)
104−import Streamly.Prelude (parallel)
104+import Streamly.Internal.Data.Stream.Concurrent (eager)
105105import System.Win32.File
106106 ( FileNotificationFlag
107107 , LPOVERLAPPED
@@ -126,6 +126,7 @@ import qualified Streamly.Internal.Data.Stream as S
126126import qualified Streamly.Internal.Unicode.Stream as U
127127import qualified Streamly.Internal.Unicode.Utf8 as UTF8
128128import qualified Streamly.Internal.Data.Array.Unboxed as A
129+import qualified Streamly.Internal.Data.Stream.Concurrent as Concur
129130import Streamly.Internal.Data.Array.Unboxed (Array)
130131
131132-- | Watch configuration, used to specify the events of interest and the
@@ -478,7 +479,7 @@ closePathHandleStream =
478479--
479480watchWith :: (Config -> Config) -> NonEmpty (Array Word8) -> Stream IO Event
480481watchWith f paths =
481− S.bracket before after (S.concatMapWith parallel eventStreamAggr)
482+ S.bracket before after (Concur.concatMapWith eager eventStreamAggr)
482483
483484 where
484485