push

README.md

@@ -43,23 +43,37 @@ rpclibrary offers a special type of call that can be used with callbacks
 ```typescript
 import {Backend, Frontend, Utils} from 'rpclibrary'
 
-const callbacks:Function[] = []
-const callbackserver = new Backend.RPCServer(20000, [{
+const callbacks:Map<string, Function> = new Map()
+
+const server = new Backend.RPCServer(20000, [{
     name: 'HelloWorldRPCGroup',
     exportRPCs: ()  => [
-        function  triggerCallbacks(message){ callbacks.forEach(cb => cb(message)) },
+        function  triggerCallbacks(...messages){ callbacks.forEach(cb => cb.apply({}, messages)) },
         {
             name: 'subscribe',
-            hook: async (callback) => {callbacks.push(callback); return Utils.makeSubResponse()}
+            hook: async (callback) => {
+                const resp = Utils.makeSubResponse()
+                callbacks.set(resp.uuid, callback); 
+                return resp
+            }
+        },{
+            name: 'unsubscribe',
+            call: async (uuid) => { callbacks.delete(uuid) }
         }
     ]
 }])
 
-const callbackclient = new Frontend.RPCSocket(20000, 'localhost')
-callbackclient.connect().then(async () => {
-    const r0 = await client['HelloWorldRPCGroup'].subscribe(console.log)
-    console.log(r0)
-    await client['HelloWorldRPCGroup'].triggerCallbacks("Hello!")
+const client = new Frontend.RPCSocket(20000, 'localhost')
+client.connect().then(async () => {
+    const res = await client['HelloWorldRPCGroup'].subscribe(async (...args:any) => {
+        console.log.apply(console, args)
+
+        /* close the callbacks once you're done */
+        await client['HelloWorldRPCGroup'].unsubscribe(res.uuid)
+        client.unhook(res.uuid)
+    })
+
+    await client['HelloWorldRPCGroup'].triggerCallbacks("Hello", "World", "Callbacks")
 })
 ```