Rename ConcurrencyError to AsyncError

propensive · Dec 27, 2024 · 63944a2 · 63944a2
1 parent ffc4665
commit 63944a2
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/src/core/turbulence-core.scala b/src/core/turbulence-core.scala
@@ -93,7 +93,7 @@ extension [ElementType](stream: LazyList[ElementType])
   def strict: LazyList[ElementType] = stream.length yet stream
 
   def rate[DurationType: GenericDuration: SpecificDuration](duration: DurationType)
-     (using Monitor, Tactic[ConcurrencyError])
+     (using Monitor, Tactic[AsyncError])
           : LazyList[ElementType] =
 
     def recur(stream: LazyList[ElementType], last: Long): LazyList[ElementType] =
@@ -214,7 +214,7 @@ extension (obj: LazyList.type)
       try
         snooze(startTime + duration.milliseconds*iteration)
         () #:: pulsar(duration)
-      catch case err: ConcurrencyError => LazyList()
+      catch case err: AsyncError => LazyList()
 
     recur(0)
 

diff --git a/src/core/turbulence.Pulsar.scala b/src/core/turbulence.Pulsar.scala
@@ -29,4 +29,4 @@ class Pulsar[DurationType: GenericDuration](duration: DurationType):
     if !continue then LazyList() else try
       sleep(duration)
       () #:: stream
-    catch case err: ConcurrencyError => LazyList()
+    catch case err: AsyncError => LazyList()