Revert "Change failure propagation from opt-in to opt-out"

This reverts commit 34aee8b.
akkadotnet · Jul 25, 2024 · 6956f97 · 6956f97
1 parent ec650a4
commit 6956f97
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/core/Akka.Streams/Dsl/Internal/InternalFlowOperations.cs b/src/core/Akka.Streams/Dsl/Internal/InternalFlowOperations.cs
@@ -2528,7 +2528,7 @@ public static IFlow<TOut, TMat3> AlsoToMaterialized<TOut, TMat, TMat2, TMat3>(
             this IFlow<TOut, TMat> flow, IGraph<SinkShape<TOut>, TMat2> that,
             Func<TMat, TMat2, TMat3> materializerFunction)
         {
-            return flow.ViaMaterialized(AlsoToGraph(that, true), materializerFunction);
+            return flow.ViaMaterialized(AlsoToGraph(that, false), materializerFunction);
         }
 
         /// <summary>
@@ -2566,7 +2566,7 @@ public static IFlow<TOut, TMat3> AlsoToMaterialized<TOut, TMat, TMat2, TMat3>(
         /// <returns>TBD</returns>
         public static IFlow<TOut, TMat> AlsoTo<TOut, TMat>(this IFlow<TOut, TMat> flow, IGraph<SinkShape<TOut>, TMat> that)
         {
-            return flow.Via(AlsoToGraph(that, true));
+            return flow.Via(AlsoToGraph(that, false));
         }
 
         /// <summary>