Add method to register service

netifi · Jul 7, 2019 · 2eb3bb1 · 2eb3bb1
1 parent ccbf307
commit 2eb3bb1
Show file tree

Hide file tree

Showing 3 changed files with 11 additions and 1 deletion.
diff --git a/Netifi.Broker.Client/BrokerClient.cs b/Netifi.Broker.Client/BrokerClient.cs
@@ -6,6 +6,7 @@
 using System.Threading;
 using System.Threading.Tasks;
 using RSocket;
+using RSocket.RPC;
 
 namespace Netifi.Broker.Client
 {
@@ -66,6 +67,11 @@ public async Task ConnectAsync()
             await client.ConnectAsync(options, metadata: writeSetupMetadata());
         }
 
+        public void AddService(IRSocketService service)
+        {
+            RSocketService.Register(client, service);
+        }
+
         public RSocket.RSocket Group(string group, SortedDictionary<string, string> tags = default)
         {
             return new BrokerSocket(client, metadata =>

diff --git a/Netifi.Broker.Client/Netifi.Broker.Client.csproj b/Netifi.Broker.Client/Netifi.Broker.Client.csproj
@@ -9,4 +9,8 @@
   <ItemGroup>
     <ProjectReference Include="..\Netifi.Broker.Frames\Netifi.Broker.Frames.csproj" />
   </ItemGroup>
+
+  <ItemGroup>
+    <PackageReference Include="RSocket.Rpc.Core" Version="0.2.10" />
+  </ItemGroup>
 </Project>
diff --git a/Netifi.Broker.Idl/Netifi.Broker.Idl.csproj b/Netifi.Broker.Idl/Netifi.Broker.Idl.csproj
@@ -12,7 +12,7 @@
       <PrivateAssets>all</PrivateAssets>
       <IncludeAssets>runtime; build; native; contentfiles; analyzers</IncludeAssets>
     </PackageReference>
-    <PackageReference Include="RSocket.Rpc.Core" Version="0.2.9" />
+    <PackageReference Include="RSocket.Rpc.Core" Version="0.2.10" />
   </ItemGroup>
 
   <ItemGroup>