diff --git a/src/CoreApi/PubSubApi.cs b/src/CoreApi/PubSubApi.cs
index c1bccbb..f2c726d 100644
--- a/src/CoreApi/PubSubApi.cs
+++ b/src/CoreApi/PubSubApi.cs
@@ -45,7 +45,7 @@ public Task PublishAsync(string topic, byte[] message, CancellationToken cancel
         {
             var url = new StringBuilder();
             url.Append("/api/v0/pubsub/pub");
-            url.Append("?arg=u");
+            url.Append("?arg=");
             url.Append(Multibase.Encode(MultibaseEncoding.Base64Url, Encoding.UTF8.GetBytes(topic)));
 
             return ipfs.DoCommandAsync(new Uri(ipfs.ApiUri, url.ToString()), message, cancel);
@@ -55,7 +55,7 @@ public Task PublishAsync(string topic, Stream message, CancellationToken cancel
         {
             var url = new StringBuilder();
             url.Append("/api/v0/pubsub/pub");
-            url.Append("?arg=u");
+            url.Append("?arg=");
             url.Append(Multibase.Encode(MultibaseEncoding.Base64Url, Encoding.UTF8.GetBytes(topic)));
 
             return ipfs.DoCommandAsync(new Uri(ipfs.ApiUri, url.ToString()), message, cancel);
@@ -65,7 +65,7 @@ public async Task PublishAsync(string topic, string message, CancellationToken c
         {
             var url = new StringBuilder();
             url.Append("/api/v0/pubsub/pub");
-            url.Append("?arg=u");
+            url.Append("?arg=");
             url.Append(Multibase.Encode(MultibaseEncoding.Base64Url, Encoding.UTF8.GetBytes(topic)));
 
             await ipfs.DoCommandAsync(new Uri(ipfs.ApiUri, url.ToString()), message, cancel);
@@ -73,7 +73,7 @@ public async Task PublishAsync(string topic, string message, CancellationToken c
 
         public async Task SubscribeAsync(string topic, Action<IPublishedMessage> handler, CancellationToken cancellationToken)
         {
-            var messageStream = await ipfs.PostDownloadAsync("pubsub/sub", cancellationToken, $"u{Multibase.Encode(MultibaseEncoding.Base64Url, Encoding.UTF8.GetBytes(topic))}");
+            var messageStream = await ipfs.PostDownloadAsync("pubsub/sub", cancellationToken, $"{Multibase.Encode(MultibaseEncoding.Base64Url, Encoding.UTF8.GetBytes(topic))}");
             var sr = new StreamReader(messageStream);
 
             _ = Task.Run(() => ProcessMessages(topic, handler, sr, cancellationToken), cancellationToken);
diff --git a/src/IpfsHttpClient.csproj b/src/IpfsHttpClient.csproj
index c98125d..8cd765e 100644
--- a/src/IpfsHttpClient.csproj
+++ b/src/IpfsHttpClient.csproj
@@ -9,7 +9,7 @@
     <TreatWarningsAsErrors>true</TreatWarningsAsErrors>
 
     <!-- https://semver.org/spec/v2.0.0.html -->
-    <Version>0.0.3</Version>
+    <Version>0.0.4</Version>
     <AssemblyVersion>$(Version)</AssemblyVersion>
 
     <!-- Nuget specs -->