Merge pull request #155 from nats-io/fix-race

Fix race condition
nats-io · Apr 18, 2017 · 9e98917 · 9e98917
2 parents fd19890 + 23492ff
commit 9e98917
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/NATS.Client/AsyncSub.cs b/NATS.Client/AsyncSub.cs
@@ -66,7 +66,10 @@ internal protected override bool processMsg(Msg msg)
                 if (d == max)
                 {
                     unsubscribe(false);
-                    conn = null;
+                    lock (mu)
+                    {
+                        conn = null;
+                    }
                 }
             }