From 651cf4986b4179b3a783a268087144a8b1888a5c Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E8=AF=BA=E5=A2=A8=E5=90=8C=E5=AD=A6?= Date: Mon, 21 Oct 2019 14:05:20 +0800 Subject: [PATCH 1/2] 1231231 --- akka.net/src/benchmark/PingPong/Program.cs | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/akka.net/src/benchmark/PingPong/Program.cs b/akka.net/src/benchmark/PingPong/Program.cs index 01c0d4b..306b07c 100644 --- a/akka.net/src/benchmark/PingPong/Program.cs +++ b/akka.net/src/benchmark/PingPong/Program.cs @@ -1,4 +1,4 @@ -//----------------------------------------------------------------------- +//----------------------------------------------------------------------- // // Copyright (C) 2009-2015 Typesafe Inc. // Copyright (C) 2013-2015 Akka.NET project @@ -149,11 +149,11 @@ namespace PingPong yield return 5; yield return 10; yield return 15; - for(int i = 20; i < 100; i += 10) + for(int i = 20; i < 100; i =+ 10) { yield return i; } - for(int i = 100; i < 1000; i += 100) + for(int i = 100; i < 1000; i = + 100) { yield return i; } -- Gitee From f9921743986b2dc31006e04043cf543dea490c26 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E8=AF=BA=E5=A2=A8=E5=90=8C=E5=AD=A6?= Date: Mon, 21 Oct 2019 14:06:34 +0800 Subject: [PATCH 2/2] 111 --- .../PublishSubscribe/DistributedPubSubMediator.cs | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/akka.net/src/contrib/cluster/Akka.Cluster.Tools/PublishSubscribe/DistributedPubSubMediator.cs b/akka.net/src/contrib/cluster/Akka.Cluster.Tools/PublishSubscribe/DistributedPubSubMediator.cs index cabc264..dd56f33 100644 --- a/akka.net/src/contrib/cluster/Akka.Cluster.Tools/PublishSubscribe/DistributedPubSubMediator.cs +++ b/akka.net/src/contrib/cluster/Akka.Cluster.Tools/PublishSubscribe/DistributedPubSubMediator.cs @@ -1,4 +1,4 @@ -//----------------------------------------------------------------------- +//----------------------------------------------------------------------- // // Copyright (C) 2009-2015 Typesafe Inc. // Copyright (C) 2013-2015 Akka.NET project @@ -369,7 +369,7 @@ namespace Akka.Cluster.Tools.PublishSubscribe .Aggregate(ImmutableDictionary.Empty, (current, kv) => current.SetItem(kv.Key, kv.Value)); - count += deltaContent.Count; + count = + deltaContent.Count; if (count <= _settings.MaxDeltaElements) yield return new Bucket(bucket.Owner, bucket.Version, deltaContent); -- Gitee