package Ġkol lect Ċ Ċ import Ġarrow . Kind Ċ import Ġarrow . core . Tuple 2 Ċ import Ġarrow . data . Non Empty List Ċ import Ġarrow . data . extensions . none mpty list . fold able . traverse _ Ċ import Ġarrow . effects . type classes . Concurrent Ċ import Ġkotlinx . coroutines . Dispatch ers Ċ Ċ internal Ġobject ĠK ol lect Execution Ġ{ ĊĊĠĠĠ Ġfun Ġ< F , ĠA > Ġparallel ( CF : ĠConcurrent < F >, Ġeffects : ĠNon Empty List < Kind < F , ĠA >> ): ĠKind < F , ĠNon Empty List < A >> Ġ= ĠCF . run Ġ{ ĊĠĠĠĠĠĠĠ Ġeffects . traverse ( CF ) Ġ{ Ġa Ġ-> Ġa . start F ( Dispatch ers . IO ) Ġ}. flatMap Ġ{ Ġfib ers Ġ-> ĊĠĠĠĠĠĠĠĠĠĠĠ Ġfib ers . traverse ( CF ) Ġ{ Ġit . join () Ġ}. handleError With Ġ{ Ġe Ġ-> ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġfib ers . traverse _( CF ) Ġ{ Ġfiber Ġ-> Ġfiber . cancel () Ġ} Ġ// If Ġfailed Ġthan Ġcancel Ġall Ġrunning Ġtasks ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. map 2 ( CF . raise Error ( e ), ĠTuple 2 < Unit , ĠNon Empty List < A >>:: b ) ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ} ĊĠĠĠĠĠĠĠ Ġ} ĊĠĠĠ Ġ} Ċ } Ċ