deprecate doAsyncSingleOrDrop and foreachAsyncSingleOrDrop

outwatch · Jul 1, 2022 · 06c4cca · 06c4cca
1 parent 1c183c0
commit 06c4cca
Showing 1 changed file with 10 additions and 2 deletions.
diff --git a/outwatch/src/main/scala/outwatch/EmitterBuilder.scala b/outwatch/src/main/scala/outwatch/EmitterBuilder.scala
@@ -71,11 +71,19 @@ trait EmitterBuilderExecution[+O, +R, +Exec <: EmitterBuilder.Execution] {
   @inline def foreachEffect[G[_]: RunEffect](action: O => G[Unit]): R = mapEffect(action).discard
   @inline def doEffect[G[_]: RunEffect](action: G[Unit]): R           = foreachEffect(_ => action)
 
-  @inline def foreachAsyncSingleOrDrop[G[_]: RunEffect](action: O => G[Unit]): R = mapEffectSingleOrDrop(action).discard
-  @inline def doAsyncSingleOrDrop[G[_]: RunEffect](action: G[Unit]): R           = foreachAsyncSingleOrDrop(_ => action)
   @inline def foreachFuture(action: O => Future[Unit]): R = mapFuture(action).discard
   @inline def doFuture(action: Future[Unit]): R           = foreachFuture(_ => action)
 
+  @deprecated("Use .foreachEffectSingleOrDrop(action) instead", "")
+  @inline def foreachAsyncSingleOrDrop[G[_]: RunEffect](action: O => G[Unit]): R = foreachEffectSingleOrDrop(action)
+  @deprecated("Use .doEffectSingleOrDrop(action) instead", "")
+  @inline def doAsyncSingleOrDrop[G[_]: RunEffect](action: G[Unit]): R = doEffectSingleOrDrop(action)
+
+  @inline def foreachEffectSingleOrDrop[G[_]: RunEffect](action: O => G[Unit]): R =
+    mapEffectSingleOrDrop(action).discard
+  @inline def doEffectSingleOrDrop[G[_]: RunEffect](action: G[Unit]): R =
+    foreachEffectSingleOrDrop(_ => action)
+
   @inline def via[F[_]: Sink, O2 >: O](sink: F[O2]): EmitterBuilderExecution[O, R, Exec] =
     transformSinkWithExec[O](Observer.combine(_, Observer.lift(sink)))
   @inline def dispatchWith(dispatcher: EventDispatcher[O]): R = transform(dispatcher.dispatch).discard