Skip to content

Commit d8eb29e

Browse files
committed
Should be parTraverse
1 parent 576739a commit d8eb29e

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

src/Node/WorkerBees/Aff/Pool.purs

+3-3
Original file line numberDiff line numberDiff line change
@@ -9,10 +9,10 @@ module Node.WorkerBees.Aff.Pool
99

1010
import Prelude
1111

12-
import Control.Parallel (parTraverse_)
12+
import Control.Parallel (parTraverse, parTraverse_)
1313
import Data.Array as Array
1414
import Data.Either (Either(..))
15-
import Data.Traversable (class Traversable, for, for_, sequence)
15+
import Data.Traversable (class Traversable, for_, sequence)
1616
import Data.Tuple (Tuple(..), fst, snd)
1717
import Effect.AVar (AVar)
1818
import Effect.Aff (Aff, Fiber, bracket, error, forkAff, killFiber)
@@ -94,4 +94,4 @@ poolTraverse
9494
-> f i
9595
-> Aff (f o)
9696
poolTraverse worker workerData numThreads fs =
97-
withPool worker workerData numThreads (for fs <<< invoke)
97+
withPool worker workerData numThreads (flip parTraverse fs <<< invoke)

0 commit comments

Comments
 (0)