Fix log messages

akkadotnet · Oct 5, 2016 · 3416044 · 3416044
1 parent 4a976b0
commit 3416044
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/src/core/Akka.Streams/Implementation/Fusing/Ops.cs b/src/core/Akka.Streams/Implementation/Fusing/Ops.cs
@@ -1735,7 +1735,7 @@ public Logic(Log<T> stage, Attributes inheritedAttributes) : base(stage.Shape)
                     if (IsEnabled(_logLevels.OnFailure))
                     {
                         if (_logLevels.OnFailure == LogLevel.ErrorLevel)
-                            _log.Error(ex, $"[{stage._name}] Upstream failed");
+                            _log.Error(ex, $"[{stage._name}] Upstream failed.");
                         else
                             _log.Log(_logLevels.OnFailure,
                                 $"[{stage._name}] Upstream failed, cause {ex.GetType().Name}: {ex.Message}");
@@ -1745,15 +1745,15 @@ public Logic(Log<T> stage, Attributes inheritedAttributes) : base(stage.Shape)
                 }, onUpstreamFinish: () =>
                 {
                     if (IsEnabled(_logLevels.OnFinish))
-                        _log.Log(_logLevels.OnFinish, $"[{stage._name}] Upstream finished");
+                        _log.Log(_logLevels.OnFinish, $"[{stage._name}] Upstream finished.");
 
                     CompleteStage();
                 });
 
                 SetHandler(stage.Outlet, onPull: ()=> Pull(stage.Inlet), onDownstreamFinish: () =>
                 {
                     if (IsEnabled(_logLevels.OnFinish))
-                        _log.Log(_logLevels.OnFinish, $"[{stage._name}] Downstream  finished");
+                        _log.Log(_logLevels.OnFinish, $"[{stage._name}] Downstream finished.");
 
                     CompleteStage();
                 });
@@ -2412,4 +2412,4 @@ public StatefulSelectMany(Func<Func<TIn, IEnumerable<TOut>>> concatFactory)
 
         public override string ToString() => "StatefulSelectMany";
     }
-}
+}