Rxn.DefaultMcas

durban · Jul 1, 2023 · d493b3d · d493b3d
1 parent 3a0a926
commit d493b3d
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 2 deletions.
diff --git a/async/shared/src/main/scala/dev/tauri/choam/async/AsyncReactive.scala b/async/shared/src/main/scala/dev/tauri/choam/async/AsyncReactive.scala
@@ -48,7 +48,7 @@ object AsyncReactive {
     inst
 
   def asyncReactiveForAsync[F[_]](implicit F: Async[F]): AsyncReactive[F] =
-    new AsyncReactiveImpl[F](Mcas.DefaultMcas)(F)
+    new AsyncReactiveImpl[F](Rxn.DefaultMcas)(F)
 
   private[async] class AsyncReactiveImpl[F[_]](mi: Mcas)(implicit F: Async[F])
     extends Reactive.SyncReactive[F](mi)

diff --git a/core/shared/src/main/scala/dev/tauri/choam/core/Reactive.scala b/core/shared/src/main/scala/dev/tauri/choam/core/Reactive.scala
@@ -43,7 +43,7 @@ object Reactive {
     inst
 
   def reactiveForSync[F[_]](implicit F: Sync[F]): Reactive[F] =
-    new SyncReactive[F](Mcas.DefaultMcas)(F)
+    new SyncReactive[F](Rxn.DefaultMcas)(F)
 
   private[choam] class SyncReactive[F[_]](
     final override val mcasImpl: Mcas

diff --git a/core/shared/src/main/scala/dev/tauri/choam/core/Rxn.scala b/core/shared/src/main/scala/dev/tauri/choam/core/Rxn.scala
@@ -276,6 +276,10 @@ object Rxn extends RxnInstances0 {
   private final val interruptCheckPeriod =
     16384
 
+  /** This is just exporting `DefaultMcas`, because that's in an internal package */
+  final def DefaultMcas: Mcas =
+    Mcas.DefaultMcas
+
   // API:
 
   def pure[A](a: A): Axn[A] =