fix pubsub

Author: ianopolous

src/main/java/io/ipfs/api/IPFS.java

@@ -234,7 +234,7 @@ public Object peers(String topic) throws IOException {
         }
 
         public Object pub(String topic, String data) throws IOException {
-            return retrieveAndParse("pubsub/peers?arg="+topic + "&arg=" + data);
+            return retrieveAndParse("pubsub/pub?arg="+topic + "&arg=" + data);
         }
 
         public Supplier<Object> sub(String topic) throws IOException {

src/test/java/io/ipfs/api/APITest.java

@@ -404,9 +404,11 @@ public void pubsub() throws IOException {
         String topic = "topic" + System.nanoTime();
         Supplier<Object> sub = ipfs.pubsub.sub(topic);
         Object first = sub.get();
+        Assert.assertTrue(first.equals(Collections.emptyMap()));
         String data = "Hello!";
         Object pub = ipfs.pubsub.pub(topic, data);
-        Assert.assertTrue(first.equals(Collections.emptyMap()));
+        Object second = sub.get();
+        Assert.assertTrue( ! second.equals(Collections.emptyMap()));
     }
 
     private static String toEscapedHex(byte[] in) throws IOException {