test(pubsub): make the topic unique

This should avoid timing issues on the CI server

Author: richardschneider

test/CoreApi/PubSubApiTest.cs

@@ -37,27 +37,19 @@ public void Subscribed_Topics()
             // TODO: Assert.IsTrue(peers.Length > 0);
         }
 
-        [TestMethod]
-        public void Publish()
-        {
-            var ipfs = TestFixture.Ipfs;
-            ipfs.PubSub.Publish("foo", "hello world test").Wait();
-            // TODO: test if published
-        }
-
         [TestMethod]
         public async Task Subscribe()
         {
             int messageCount = 0;
             var ipfs = TestFixture.Ipfs;
-            var topic = "net-ipfs-api-test";
+            var topic = "net-ipfs-api-test-" + Guid.NewGuid().ToString();
             await ipfs.PubSub.Subscribe(topic, msg =>
             {
                 Interlocked.Increment(ref messageCount);
             });
-            await ipfs.PubSub.Publish(topic, "hello world");
-            await ipfs.PubSub.Publish(topic, "hello world");
-            await Task.Delay(5000);
+            await ipfs.PubSub.Publish(topic, "hello world!");
+            await ipfs.PubSub.Publish(topic, "hello world!!");
+            await Task.Delay(1000);
             Assert.AreEqual(2, messageCount);
         }
 
@@ -66,20 +58,20 @@ public async Task Unsubscribe()
         {
             int messageCount = 0;
             var ipfs = TestFixture.Ipfs;
-            var topic = "net-ipfs-api-test";
+            var topic = "net-ipfs-api-test-" + Guid.NewGuid().ToString();
             var cs = new CancellationTokenSource();
             await ipfs.PubSub.Subscribe(topic, msg =>
             {
                 Interlocked.Increment(ref messageCount);
             }, cs.Token);
-            await ipfs.PubSub.Publish(topic, "hello world");
-            await ipfs.PubSub.Publish(topic, "hello world");
-            await Task.Delay(5000);
+            await ipfs.PubSub.Publish(topic, "hello world!");
+            await ipfs.PubSub.Publish(topic, "hello world!!");
+            await Task.Delay(1000);
             Assert.AreEqual(2, messageCount);
 
             cs.Cancel();
-            await ipfs.PubSub.Publish(topic, "hello world");
-            await Task.Delay(2000);
+            await ipfs.PubSub.Publish(topic, "hello world!!!");
+            await Task.Delay(1000);
             Assert.AreEqual(2, messageCount);
         }
     }