From 06c4cca2af43313a7062fbeb149ac2bf22e90b5e Mon Sep 17 00:00:00 2001 From: johannes karoff Date: Fri, 1 Jul 2022 18:30:05 +0200 Subject: [PATCH] deprecate doAsyncSingleOrDrop and foreachAsyncSingleOrDrop --- .../src/main/scala/outwatch/EmitterBuilder.scala | 12 ++++++++++-- 1 file changed, 10 insertions(+), 2 deletions(-) diff --git a/outwatch/src/main/scala/outwatch/EmitterBuilder.scala b/outwatch/src/main/scala/outwatch/EmitterBuilder.scala index 17bbaed79..2cb270016 100644 --- 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