Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

Add IO implementation of parMap #950

Merged
merged 27 commits into from Jul 24, 2018
Merged

Add IO implementation of parMap #950

Show file tree
Hide file tree
Changes from 23 commits
Commits
Show all changes
27 commits
Select commit Hold shift + click to select a range
e7a0615
Add IO implementation of parMap
Jul 22, 2018
3deea20
Update policy for resuming on the same side
Jul 22, 2018
7bf9929
Formatting
Jul 22, 2018
339c550
Formatting
Jul 22, 2018
3f2f8d4
Add triContinuation to start 3 IOs at the same time
Jul 22, 2018
03a8f04
Fix parallelization start issue with high-latency IO
Jul 22, 2018
744a35b
Add doc
Jul 22, 2018
17459b4
Reset tests to Master
Jul 22, 2018
f120361
Reset Utils to Master
Jul 22, 2018
6671ae3
Add up to parMap9
Jul 22, 2018
375be5a
Move everything to IOParallel. Unify name.
Jul 22, 2018
bc19d80
Cleanup of unnecessary lambdas
Jul 22, 2018
17bfc63
EOL
Jul 22, 2018
2781bed
Fix detekt
Jul 22, 2018
9ab7b5e
Unify behavior for par2 and par3
Jul 22, 2018
caade04
Fix formatting
Jul 22, 2018
510a741
Add a single parallelism test
Jul 22, 2018
30b0902
Add a new IO constructor for async blocks
Jul 22, 2018
266347e
Add two more parallelism tests
Jul 22, 2018
4da8037
Formatting
Jul 22, 2018
5c13637
Fix consistency
Jul 22, 2018
d940fa0
Add test for parallelism of defer and suspend
Jul 22, 2018
9b99458
Add test for parallelism of async
Jul 22, 2018
5fafeb9
Rename parMap to parallelMap for consistency
Jul 22, 2018
82bfa91
Fix doc
pakoito Jul 22, 2018
cfd75e7
Generalise ParallelUtils for all Effects, specialize for IO
Jul 24, 2018
0814e8f
Merge remote-tracking branch 'origin/paco-pario' into paco-pario
Jul 24, 2018
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Jump to
Jump to file
Failed to load files.
Diff view
Diff view
86 changes: 43 additions & 43 deletions infographic/arrow-infographic.txt
View file
Open in desktop
Expand Up @@ -8,62 +8,62 @@
#fill: #64B5F6
#.typeclasses: fill=#64B5F6 visual=database bold
#.instances: fill=#B9F6CA visual=class italic bold dashed
[<typeclasses>Applicative]<-[<typeclasses>ApplicativeError]
[<typeclasses>Functor]<-[<typeclasses>Applicative]
[<typeclasses>MonadDefer]<-[<typeclasses>Async]
[<typeclasses>Async]<-[<typeclasses>Effect]
[<typeclasses>MonadError]<-[<typeclasses>MonadDefer]
[<typeclasses>ApplicativeError]<-[<typeclasses>MonadError]
[<typeclasses>Monad]<-[<typeclasses>MonadError]
[<typeclasses>Functor]<-[<typeclasses>Comonad]
[<typeclasses>Applicative]<-[<typeclasses>ApplicativeError]
[<typeclasses>Functor]<-[<typeclasses>Traverse]
[<typeclasses>Foldable]<-[<typeclasses>Traverse]
[<typeclasses>Applicative]<-[<typeclasses>Monad]
[<typeclasses>Semigroup]<-[<typeclasses>Monoid]
[<typeclasses>Monad]<-[<typeclasses>Bimonad]
[<typeclasses>Comonad]<-[<typeclasses>Bimonad]
[<typeclasses>Functor]<-[<typeclasses>Comonad]
[<typeclasses>Functor]<-[<typeclasses>Traverse]
[<typeclasses>Foldable]<-[<typeclasses>Traverse]
[<typeclasses>SemigroupK]<-[<typeclasses>MonoidK]
[<typeclasses>MonadError]<-[<typeclasses>MonadDefer]
[<typeclasses>MonadDefer]<-[<typeclasses>Async]
[<typeclasses>Async]<-[<typeclasses>Effect]
[<typeclasses>Monad]<-[<typeclasses>MonadFilter]
[<typeclasses>FunctorFilter]<-[<typeclasses>MonadFilter]
[<typeclasses>Monad]<-[<typeclasses>MonadWriter]
[<typeclasses>Functor]<-[<typeclasses>FunctorFilter]
[<typeclasses>MonoidK]<-[<instances>MonoidK Instances|ListKMonoidKInstance|OptionTMonoidKInstance|SequenceKMonoidKInstance|SetKMonoidKInstance|WriterTMonoidKInstance]
[<typeclasses>SemigroupK]<-[<instances>SemigroupK Instances|EitherSemigroupKInstance|ListKSemigroupKInstance|NonEmptyListSemigroupKInstance|OptionTSemigroupKInstance|SequenceKSemigroupKInstance|SetKSemigroupKInstance|StateTSemigroupKInstance|ValidatedSemigroupKInstance|WriterTSemigroupKInstance]
[<typeclasses>Bimonad]<-[<instances>Bimonad Instances|EvalBimonadInstance|Function0BimonadInstance|IdBimonadInstance|NonEmptyListBimonadInstance]
[<typeclasses>Foldable]<-[<instances>Foldable Instances|ConstFoldableInstance|EitherFoldableInstance|IdFoldableInstance|OptionFoldableInstance|TryFoldableInstance|Tuple2FoldableInstance|CoproductFoldableInstance|IorFoldableInstance|ListKFoldableInstance|MapKFoldableInstance|NonEmptyListFoldableInstance|OptionTFoldableInstance|SequenceKFoldableInstance|SetKFoldableInstance|SortedMapKFoldableInstance|ValidatedFoldableInstance]
[<typeclasses>Traverse]<-[<instances>Traverse Instances|ConstTraverseInstance|EitherTraverseInstance|IdTraverseInstance|OptionTraverseInstance|TryTraverseInstance|Tuple2TraverseInstance|CoproductTraverseInstance|IorTraverseInstance|ListKTraverseInstance|MapKTraverseInstance|NonEmptyListTraverseInstance|OptionTTraverseInstance|SequenceKTraverseInstance|SortedMapKTraverseInstance|ValidatedTraverseInstance]
[<typeclasses>Eq]<-[<instances>Eq Instances|ConstEqInstance|EitherEqInstance|IdEqInstance|OptionEqInstance|TryEqInstance|Tuple10EqInstance|Tuple2EqInstance|Tuple3EqInstance|Tuple4EqInstance|Tuple5EqInstance|Tuple6EqInstance|Tuple7EqInstance|Tuple8EqInstance|Tuple9EqInstance|IorEqInstance|ListKEqInstance|MapKEqInstance|NonEmptyListEqInstance|SequenceKEqInstance|SetKEqInstance|ValidatedEqInstance]
[<typeclasses>Show]<-[<instances>Show Instances|ConstShowInstance|EitherShowInstance|IdShowInstance|OptionShowInstance|TryShowInstance|Tuple10ShowInstance|Tuple2ShowInstance|Tuple3ShowInstance|Tuple4ShowInstance|Tuple5ShowInstance|Tuple6ShowInstance|Tuple7ShowInstance|Tuple8ShowInstance|Tuple9ShowInstance|IorShowInstance|ListKShowInstance|MapKShowInstance|NonEmptyListShowInstance|SequenceKShowInstance|SetKShowInstance|SortedMapKShowInstance|ValidatedShowInstance]
[<typeclasses>Comonad]<-[<instances>Comonad Instances|EvalComonadInstance|Function0ComonadInstance|IdComonadInstance|Tuple2ComonadInstance|CofreeComonadInstance|CoproductComonadInstance|NonEmptyListComonadInstance]
[<typeclasses>Monad]<-[<typeclasses>MonadReader]
[<typeclasses>MonadReader]<-[<instances>MonadReader Instances|Function1MonadReaderInstance|KleisliMonadReaderInstance]
[<typeclasses>Functor]<-[<typeclasses>FunctorFilter]
[<typeclasses>FunctorFilter]<-[<instances>FunctorFilter Instances|ListKFunctorFilterInstance|OptionTFunctorFilterInstance]
[<typeclasses>Traverse]<-[<typeclasses>TraverseFilter]
[<typeclasses>FunctorFilter]<-[<typeclasses>TraverseFilter]
[<typeclasses>Monad]<-[<typeclasses>MonadState]
[<typeclasses>TraverseFilter]<-[<instances>TraverseFilter Instances|ConstTraverseFilterInstance|OptionTraverseFilterInstance|OptionTTraverseFilterInstance]
[<typeclasses>MonadFilter]<-[<typeclasses>MonadCombine]
[<typeclasses>Alternative]<-[<typeclasses>MonadCombine]
[<typeclasses>MonadCombine]<-[<instances>MonadCombine Instances|ListKMonadCombineInstance|StateTMonadCombineInstance]
[<typeclasses>Monad]<-[<typeclasses>MonadState]
[<typeclasses>MonadState]<-[<instances>MonadState Instances|StateTMonadStateInstance]
[<typeclasses>Monad]<-[<typeclasses>MonadFilter]
[<typeclasses>FunctorFilter]<-[<typeclasses>MonadFilter]
[<typeclasses>MonadFilter]<-[<instances>MonadFilter Instances|ListKMonadFilterInstance|OptionMonadFilterInstance|WriterTMonadFilterInstance]
[<typeclasses>Monad]<-[<typeclasses>MonadWriter]
[<typeclasses>MonadWriter]<-[<instances>MonadWriter Instances|WriterTMonadWriterInstance]
[<typeclasses>FilterIndex]<-[<instances>FilterIndex Instances|ListKFilterIndexInstance|MapKFilterIndexInstance|NonEmptyListFilterIndexInstance|SequenceKFilterIndexInstance]
[<typeclasses>Index]<-[<instances>Index Instances|ListKIndexInstance|MapKIndexInstance|NonEmptyListIndexInstance|SequenceKIndexInstance]
[<typeclasses>At]<-[<instances>At Instances|MapKAtInstance|SetKAtInstance]
[<typeclasses>Each]<-[<instances>Each Instances|EitherEachInstance|ListKEachInstance|MapKEachInstance|NonEmptyListEachInstance|OptionEachInstance|SequenceKEachInstance|TryEachInstance]
[<typeclasses>Recursive]<-[<typeclasses>Birecursive]
[<typeclasses>Corecursive]<-[<typeclasses>Birecursive]
[<typeclasses>MonoidK]<-[<instances>MonoidK Instances|OptionTMonoidKInstance|ListKMonoidKInstance|SetKMonoidKInstance|SequenceKMonoidKInstance|WriterTMonoidKInstance]
[<typeclasses>SemigroupK]<-[<instances>SemigroupK Instances|EitherSemigroupKInstance|OptionTSemigroupKInstance|SequenceKSemigroupKInstance|WriterTSemigroupKInstance|StateTSemigroupKInstance|NonEmptyListSemigroupKInstance|SetKSemigroupKInstance|ValidatedSemigroupKInstance|ListKSemigroupKInstance]
[<typeclasses>Eq]<-[<instances>Eq Instances|Tuple7EqInstance|Tuple5EqInstance|Tuple2EqInstance|EitherEqInstance|Tuple9EqInstance|Tuple3EqInstance|TryEqInstance|Tuple6EqInstance|ConstEqInstance|IdEqInstance|OptionEqInstance|Tuple10EqInstance|Tuple4EqInstance|Tuple8EqInstance|NonEmptyListEqInstance|ListKEqInstance|SetKEqInstance|IorEqInstance|SequenceKEqInstance|ValidatedEqInstance|MapKEqInstance]
[<typeclasses>Show]<-[<instances>Show Instances|Tuple3ShowInstance|IdShowInstance|OptionShowInstance|Tuple8ShowInstance|ConstShowInstance|EitherShowInstance|Tuple4ShowInstance|TryShowInstance|Tuple2ShowInstance|Tuple9ShowInstance|Tuple6ShowInstance|Tuple5ShowInstance|Tuple10ShowInstance|Tuple7ShowInstance|IorShowInstance|MapKShowInstance|SetKShowInstance|SortedMapKShowInstance|SequenceKShowInstance|ListKShowInstance|ValidatedShowInstance|NonEmptyListShowInstance]
[<typeclasses>Bimonad]<-[<instances>Bimonad Instances|EvalBimonadInstance|Function0BimonadInstance|IdBimonadInstance|NonEmptyListBimonadInstance]
[<typeclasses>FilterIndex]<-[<instances>FilterIndex Instances|SequenceKFilterIndexInstance|MapKFilterIndexInstance|ListKFilterIndexInstance|NonEmptyListFilterIndexInstance]
[<typeclasses>Index]<-[<instances>Index Instances|MapKIndexInstance|SequenceKIndexInstance|NonEmptyListIndexInstance|ListKIndexInstance|NonEmptyListFilterIndexInstance|MapKFilterIndexInstance|SequenceKFilterIndexInstance|ListKFilterIndexInstance]
[<typeclasses>At]<-[<instances>At Instances|MapKAtInstance|SetKAtInstance]
[<typeclasses>Each]<-[<instances>Each Instances|ListKEachInstance|OptionEachInstance|EitherEachInstance|TryEachInstance|SequenceKEachInstance|NonEmptyListEachInstance|MapKEachInstance]
[<typeclasses>Semigroup]<-[<instances>Semigroup Instances|ConstSemigroupInstance|OptionSemigroupInstance|SortedMapKSemigroupInstance|ListKSemigroupInstance|MapKSemigroupInstance|SetKSemigroupInstance|SequenceKSemigroupInstance|NonEmptyListSemigroupInstance|IOSemigroupInstance|IOMonoidInstance|EitherSemigroupInstance|TrySemigroupInstance]
[<typeclasses>Monoid]<-[<instances>Monoid Instances|OptionMonoidInstance|ConstMonoidInstance|Tuple2MonoidInstance|SequenceKMonoidInstance|SortedMapKMonoidInstance|ListKMonoidInstance|MapKMonoidInstance|SetKMonoidInstance|IOMonoidInstance|TryMonoidInstance|EitherMonoidInstance]
[<typeclasses>Traverse]<-[<instances>Traverse Instances|EitherTraverseInstance|OptionTraverseInstance|Tuple2TraverseInstance|TryTraverseInstance|IdTraverseInstance|ConstTraverseInstance|IorTraverseInstance|MapKTraverseInstance|ValidatedTraverseInstance|CoproductTraverseInstance|ListKTraverseInstance|SequenceKTraverseInstance|OptionTTraverseInstance|NonEmptyListTraverseInstance|SortedMapKTraverseInstance|FlowableKTraverseInstance|ObservableKTraverseInstance|FluxKTraverseInstance]
[<typeclasses>Foldable]<-[<instances>Foldable Instances|ConstFoldableInstance|IdFoldableInstance|EitherFoldableInstance|TryFoldableInstance|OptionFoldableInstance|Tuple2FoldableInstance|OptionTFoldableInstance|MapKFoldableInstance|SetKFoldableInstance|ListKFoldableInstance|NonEmptyListFoldableInstance|IorFoldableInstance|SequenceKFoldableInstance|SortedMapKFoldableInstance|CoproductFoldableInstance|ValidatedFoldableInstance|MaybeKFoldableInstance|FlowableKFoldableInstance|ObservableKFoldableInstance|FluxKFoldableInstance]
[<typeclasses>MonadDefer]<-[<instances>MonadDefer Instances|IOMonadDeferInstance|DeferredKMonadDeferInstance|ObservableKMonadDeferInstance|MaybeKMonadDeferInstance|SingleKMonadDeferInstance|FlowableKMonadDeferInstance|FluxKMonadDeferInstance|MonoKMonadDeferInstance]
[<typeclasses>Async]<-[<instances>Async Instances|IOAsyncInstance|DeferredKAsyncInstance|MaybeKAsyncInstance|SingleKAsyncInstance|ObservableKAsyncInstance|FlowableKAsyncInstance|MonoKAsyncInstance|FluxKAsyncInstance]
[<typeclasses>Effect]<-[<instances>Effect Instances|IOEffectInstance|DeferredKEffectInstance|MaybeKEffectInstance|ObservableKEffectInstance|SingleKEffectInstance|FlowableKEffectInstance|FluxKEffectInstance|MonoKEffectInstance]
[<typeclasses>MonadError]<-[<instances>MonadError Instances|EitherMonadErrorInstance|TryMonadErrorInstance|OptionMonadErrorInstance|StateTMonadErrorInstance|KleisliMonadErrorInstance|IOMonadErrorInstance|DeferredKMonadErrorInstance|MaybeKMonadErrorInstance|ObservableKMonadErrorInstance|SingleKMonadErrorInstance|FlowableKMonadErrorInstance|FluxKMonadErrorInstance|MonoKMonadErrorInstance]
[<typeclasses>ApplicativeError]<-[<instances>ApplicativeError Instances|OptionApplicativeErrorInstance|TryApplicativeErrorInstance|EitherApplicativeErrorInstance|StateTApplicativeErrorInstance|KleisliApplicativeErrorInstance|ValidatedApplicativeErrorInstance|IOApplicativeErrorInstance|DeferredKApplicativeErrorInstance|SingleKApplicativeErrorInstance|ObservableKApplicativeErrorInstance|MaybeKApplicativeErrorInstance|FlowableKApplicativeErrorInstance|FluxKApplicativeErrorInstance|MonoKApplicativeErrorInstance]
[<typeclasses>Comonad]<-[<instances>Comonad Instances|Tuple2ComonadInstance|IdComonadInstance|Function0ComonadInstance|EvalComonadInstance|CoproductComonadInstance|NonEmptyListComonadInstance|CofreeComonadInstance]
[<typeclasses>Applicative]<-[<instances>Applicative Instances|Function1ApplicativeInstance|IdApplicativeInstance|Tuple2ApplicativeInstance|Function0ApplicativeInstance|ConstApplicativeInstance|OptionApplicativeInstance|EvalApplicativeInstance|EitherApplicativeInstance|TryApplicativeInstance|ListKApplicativeInstance|ValidatedApplicativeInstance|IorApplicativeInstance|WriterTApplicativeInstance|NonEmptyListApplicativeInstance|KleisliApplicativeInstance|StateTApplicativeInstance|SequenceKApplicativeInstance|OptionTApplicativeInstance|IOApplicativeInstance|FreeApplicativeInstance|FreeApplicativeApplicativeInstance|DeferredKApplicativeInstance|MaybeKApplicativeInstance|ObservableKApplicativeInstance|FlowableKApplicativeInstance|SingleKApplicativeInstance|FluxKApplicativeInstance|MonoKApplicativeInstance]
[<typeclasses>Monad]<-[<instances>Monad Instances|Function1MonadInstance|Function0MonadInstance|EitherMonadInstance|IdMonadInstance|TryMonadInstance|Tuple2MonadInstance|EvalMonadInstance|OptionMonadInstance|NonEmptyListMonadInstance|OptionTMonadInstance|WriterTMonadInstance|SequenceKMonadInstance|IorMonadInstance|StateTMonadInstance|KleisliMonadInstance|ListKMonadInstance|IOMonadInstance|FreeMonadInstance|DeferredKMonadInstance|SingleKMonadInstance|MaybeKMonadInstance|FlowableKMonadInstance|ObservableKMonadInstance|FluxKMonadInstance|MonoKMonadInstance]
[<typeclasses>MonadFilter]<-[<instances>MonadFilter Instances|WriterTMonadFilterInstance|OptionMonadFilterInstance|ListKMonadFilterInstance]
[<typeclasses>MonadWriter]<-[<instances>MonadWriter Instances|WriterTMonadWriterInstance]
[<typeclasses>FunctorFilter]<-[<instances>FunctorFilter Instances|ListKFunctorFilterInstance|OptionTFunctorFilterInstance]
[<typeclasses>MonadReader]<-[<instances>MonadReader Instances|Function1MonadReaderInstance|KleisliMonadReaderInstance]
[<typeclasses>TraverseFilter]<-[<instances>TraverseFilter Instances|OptionTraverseFilterInstance|OptionTTraverseFilterInstance|ConstTraverseFilterInstance]
[<typeclasses>MonadState]<-[<instances>MonadState Instances|StateTMonadStateInstance]
[<typeclasses>MonadCombine]<-[<instances>MonadCombine Instances|ListKMonadCombineInstance|StateTMonadCombineInstance]
[<typeclasses>Corecursive]<-[<instances>Corecursive Instances|MuCorecursiveInstance|FixCorecursiveInstance|NuCorecursiveInstance]
[<typeclasses>Birecursive]<-[<instances>Birecursive Instances|FixBirecursiveInstance|MuBirecursiveInstance|NuBirecursiveInstance]
[<typeclasses>Recursive]<-[<instances>Recursive Instances|MuRecursiveInstance|FixRecursiveInstance|NuRecursiveInstance]
[<typeclasses>Functor]<-[<instances>Functor Instances|ConstFunctorInstance|OptionFunctorInstance|Function1FunctorInstance|Tuple2FunctorInstance|TryFunctorInstance|IdFunctorInstance|EvalFunctorInstance|EitherFunctorInstance|Function0FunctorInstance|MapKFunctorInstance|SortedMapKFunctorInstance|CoproductFunctorInstance|OptionTFunctorInstance|IorFunctorInstance|StateTFunctorInstance|ValidatedFunctorInstance|SequenceKFunctorInstance|WriterTFunctorInstance|ListKFunctorInstance|KleisliFunctorInstance|NonEmptyListFunctorInstance|IOFunctorInstance|CofreeFunctorInstance|YonedaFunctorInstance|FreeFunctorInstance|CoyonedaFunctorInstance|FreeApplicativeFunctorInstance|DeferredKFunctorInstance|MaybeKFunctorInstance|SingleKFunctorInstance|FlowableKFunctorInstance|ObservableKFunctorInstance|MonoKFunctorInstance|FluxKFunctorInstance|IntListPatternFunctorInstance]
[<typeclasses>Corecursive]<-[<instances>Corecursive Instances|FixCorecursiveInstance|MuCorecursiveInstance|NuCorecursiveInstance]
[<typeclasses>Recursive]<-[<instances>Recursive Instances|FixRecursiveInstance|MuRecursiveInstance|NuRecursiveInstance]
[<typeclasses>Async]<-[<instances>Async Instances|IOAsyncInstance]
[<typeclasses>Effect]<-[<instances>Effect Instances|IOEffectInstance]
[<typeclasses>MonadDefer]<-[<instances>MonadDefer Instances|IOMonadDeferInstance]
[<typeclasses>ApplicativeError]<-[<instances>ApplicativeError Instances|IOApplicativeErrorInstance|EitherApplicativeErrorInstance|OptionApplicativeErrorInstance|TryApplicativeErrorInstance|KleisliApplicativeErrorInstance|StateTApplicativeErrorInstance|ValidatedApplicativeErrorInstance]
[<typeclasses>MonadError]<-[<instances>MonadError Instances|IOMonadErrorInstance|EitherMonadErrorInstance|OptionMonadErrorInstance|TryMonadErrorInstance|KleisliMonadErrorInstance|StateTMonadErrorInstance]
[<typeclasses>Monoid]<-[<instances>Monoid Instances|IOMonoidInstance|ConstMonoidInstance|EitherMonoidInstance|OptionMonoidInstance|TryMonoidInstance|Tuple2MonoidInstance|ListKMonoidInstance|MapKMonoidInstance|SequenceKMonoidInstance|SetKMonoidInstance|SortedMapKMonoidInstance]
[<typeclasses>Semigroup]<-[<instances>Semigroup Instances|IOMonoidInstance|IOSemigroupInstance|ConstSemigroupInstance|EitherSemigroupInstance|OptionSemigroupInstance|TrySemigroupInstance|ListKSemigroupInstance|MapKSemigroupInstance|NonEmptyListSemigroupInstance|SequenceKSemigroupInstance|SetKSemigroupInstance|SortedMapKSemigroupInstance]
[<typeclasses>Applicative]<-[<instances>Applicative Instances|IOApplicativeInstance|ConstApplicativeInstance|EitherApplicativeInstance|EvalApplicativeInstance|Function0ApplicativeInstance|Function1ApplicativeInstance|IdApplicativeInstance|OptionApplicativeInstance|TryApplicativeInstance|Tuple2ApplicativeInstance|FreeApplicativeApplicativeInstance|FreeApplicativeInstance|IorApplicativeInstance|KleisliApplicativeInstance|ListKApplicativeInstance|NonEmptyListApplicativeInstance|OptionTApplicativeInstance|SequenceKApplicativeInstance|StateTApplicativeInstance|ValidatedApplicativeInstance|WriterTApplicativeInstance]
[<typeclasses>Functor]<-[<instances>Functor Instances|IOFunctorInstance|ConstFunctorInstance|EitherFunctorInstance|EvalFunctorInstance|Function0FunctorInstance|Function1FunctorInstance|IdFunctorInstance|OptionFunctorInstance|TryFunctorInstance|Tuple2FunctorInstance|CofreeFunctorInstance|CoyonedaFunctorInstance|FreeApplicativeFunctorInstance|FreeFunctorInstance|YonedaFunctorInstance|CoproductFunctorInstance|IorFunctorInstance|KleisliFunctorInstance|ListKFunctorInstance|MapKFunctorInstance|NonEmptyListFunctorInstance|OptionTFunctorInstance|SequenceKFunctorInstance|SortedMapKFunctorInstance|StateTFunctorInstance|ValidatedFunctorInstance|WriterTFunctorInstance]
[<typeclasses>Monad]<-[<instances>Monad Instances|IOMonadInstance|EitherMonadInstance|EvalMonadInstance|Function0MonadInstance|Function1MonadInstance|IdMonadInstance|OptionMonadInstance|TryMonadInstance|Tuple2MonadInstance|FreeMonadInstance|IorMonadInstance|KleisliMonadInstance|ListKMonadInstance|NonEmptyListMonadInstance|OptionTMonadInstance|SequenceKMonadInstance|StateTMonadInstance|WriterTMonadInstance]
5 changes: 5 additions & 0 deletions modules/effects/arrow-effects/src/main/kotlin/arrow/effects/IO.kt
View file
Open in desktop
Expand Up @@ -36,6 +36,9 @@ sealed class IO<out A> : IOOf<A> {
}
}

fun <A> async(ctx: CoroutineContext, f: () -> A): IO<A> =
IO.unit.continueOn(ctx).flatMap { Pure(f()) }

val unit: IO<Unit> =
just(Unit)

Expand All @@ -55,6 +58,8 @@ sealed class IO<out A> : IOOf<A> {
is Either.Right -> IO.just(it.b)
}
}

/* For parMap, look into IOParallel */
}

abstract fun <B> map(f: (A) -> B): IO<B>
Expand Down