Merge pull request #44 from xconnio/update-examples

update call & publish examples

Author: Mahad-10

README.md

@@ -51,7 +51,7 @@ import {Session} from "xconn";
 
 
 async function examplePublish(session: Session) {
-    await session.publish("io.xconn.example", {args: ["test"], kwargs: {"key": "value"}});
+    await session.publish("io.xconn.example", ["test"], {"key": "value"});
 }
 ```
 
@@ -78,7 +78,7 @@ import {Session} from "xconn";
 
 
 async function exampleCall(session: Session) {
-    await session.call("io.xconn.echo", {args: [1, 2], kwargs: {"key": "value"}});
+    await session.call("io.xconn.echo", [1, 2], {"key": "value"});
 }
 ```
 

examples/pubsub/publisher.ts

@@ -8,23 +8,19 @@ async function main() {
     await session.publish(testTopic);
 
     // publish event with args
-    await session.publish(testTopic, {args: ["Hello", "World"]});
+    await session.publish(testTopic, ["Hello", "World"]);
 
     // publish event with kwargs
-    await session.publish(testTopic, {kwargs: {"key": "value"}});
+    await session.publish(testTopic, [], {"key": "value"});
 
     // publish event with options
-    await session.publish(testTopic, {options: {"acknowledge": true}});
+    await session.publish(testTopic,[], {}, {"acknowledge": true});
 
     // publish event with args & kwargs
-    await session.publish(testTopic, {args: ["Hello", "World"], kwargs: {"key": "value"}});
+    await session.publish(testTopic, ["Hello", "World"], {"key": "value"});
 
     // publish event with args, kwargs & options
-    await session.publish(testTopic, {
-        args: ["Hello", "World"],
-        kwargs: {"key": "value"},
-        options: {"acknowledge": true}
-    });
+    await session.publish(testTopic, ["Hello", "World"], {"key": "value"}, {"acknowledge": true});
 
     console.log(`Published events to ${testTopic}`);
 

examples/rpc/caller.ts

@@ -8,30 +8,24 @@ async function main() {
     const session = await connectAnonymous("ws://localhost:8080/ws", "realm1");
 
     // Call procedure "io.xconn.echo" with args and kwargs
-    const result: Result = await session.call(testProcedureEcho, {
-        args: ["hello", "world"],
-        kwargs: {key: "value"},
-    });
+    const result: Result = await session.call(testProcedureEcho, ["hello", "world"], {key: "value"});
     console.log(`Result of procedure '${testProcedureEcho}': args=${result.args}, kwargs=${result.kwargs}`);
 
     // Call with only args
-    await session.call(testProcedureEcho, {args: ["hello", "world"]});
+    await session.call(testProcedureEcho, ["hello", "world"]);
 
     // Call with only kwargs
-    await session.call(testProcedureEcho, {kwargs: {name: "john"}});
+    await session.call(testProcedureEcho, [], {name: "john"});
 
     // Call with both args and kwargs
-    await session.call(testProcedureEcho, {args: [1, 2], kwargs: {name: "john"}});
+    await session.call(testProcedureEcho, [1, 2], {name: "john"});
 
     // Call procedure "io.xconn.async.echo" with args and kwargs
-    const resultAsync: Result = await session.call(testProcedureAsyncEcho, {
-        args: ["hello", "xconn"],
-        kwargs: {key: "value"},
-    });
+    const resultAsync: Result = await session.call(testProcedureAsyncEcho, ["hello", "xconn"], {key: "value"});
     console.log(`Result of procedure '${testProcedureAsyncEcho}': args=${resultAsync.args}, kwargs=${resultAsync.kwargs}`);
 
     // Call sum procedure and print result
-    const sumResult: Result = await session.call(testProcedureSum, {args: [2, 2, 6]});
+    const sumResult: Result = await session.call(testProcedureSum, [2, 2, 6]);
     console.log(`Sum=${sumResult.args?.[0]}`);
 
     await session.close();