@@ -101,7 +101,7 @@ import Foreign.Marshal.Alloc (alloca, allocaBytes)
101import Foreign.Storable (peekByteOff)
101import Foreign.Storable (peekByteOff)
102import Foreign.Ptr (Ptr, FunPtr, castPtr, nullPtr, nullFunPtr, plusPtr)
102import Foreign.Ptr (Ptr, FunPtr, castPtr, nullPtr, nullFunPtr, plusPtr)
103import Streamly.Internal.Data.Stream (Stream)
103import Streamly.Internal.Data.Stream (Stream)
104−import Streamly.Prelude (parallel)
104+import Streamly.Internal.Data.Stream.Concurrent (eager)
105import System.Win32.File
105import System.Win32.File
106 ( FileNotificationFlag
106 ( FileNotificationFlag
107 , LPOVERLAPPED
107 , LPOVERLAPPED
@@ -126,6 +126,7 @@ import qualified Streamly.Internal.Data.Stream as S
126import qualified Streamly.Internal.Unicode.Stream as U
126import qualified Streamly.Internal.Unicode.Stream as U
127import qualified Streamly.Internal.Unicode.Utf8 as UTF8
127import qualified Streamly.Internal.Unicode.Utf8 as UTF8
128import qualified Streamly.Internal.Data.Array.Unboxed as A
128import qualified Streamly.Internal.Data.Array.Unboxed as A
129+import qualified Streamly.Internal.Data.Stream.Concurrent as Concur
129import Streamly.Internal.Data.Array.Unboxed (Array)
130import Streamly.Internal.Data.Array.Unboxed (Array)
131-- | Watch configuration, used to specify the events of interest and the
132-- | Watch configuration, used to specify the events of interest and the
@@ -478,7 +479,7 @@ closePathHandleStream =
479watchWith :: (Config -> Config) -> NonEmpty (Array Word8) -> Stream IO Event
480watchWith :: (Config -> Config) -> NonEmpty (Array Word8) -> Stream IO Event
480watchWith f paths =
481watchWith f paths =
481− S.bracket before after (S.concatMapWith parallel eventStreamAggr)
482+ S.bracket before after (Concur.concatMapWith eager eventStreamAggr)