Feat. Added support to async and pooled invocations

Author: sleipnir

example/spawn_example.py

@@ -14,8 +14,9 @@
     request.language = "erlang"
 
     spawn = Spawn()
+    # .add_actor(joe_actor)
     spawn.port(8091).proxy_port(9003).actor_system(
-        "spawn-system").add_actor(joe_actor).add_actor(abstract).start()
+        "spawn-system").add_actor(abstract).start()
 
     # Get abstract actor reference called mike
     mike_actor: ActorRef = Spawn.create_actor_ref(
@@ -24,6 +25,7 @@
         parent="abs_actor"
     )
 
-    (status, result) = mike_actor.invoke("setLanguage", request)
+    (status, result) = mike_actor.invoke(
+        action="setLanguage", request=request)
     print("Invocation Result Status: " + status)
     print("Invocation Result Value:  " + str(result.response))

spawn/eigr/functions/actors/api/reference.py

@@ -43,14 +43,15 @@ def __init__(self, client: SpawnClient, system: str, actor: str, parent: str = N
             spawn(self.__spawn_client, self.actor_system,
                   self.actor_name, self.actor_parent, self.revision)
 
-    def invoke(self, action: str, request: any = None):
-        req: InvocationRequest = self.__build_request(action, request)
+    def invoke(self, action: str, request: any = None, async_mode: bool = False, pooled: bool = False):
+        req: InvocationRequest = self.__build_request(
+            action, request, async_mode, pooled)
         resp: InvocationResponse = self.__spawn_client.invoke(
             self.actor_system, self.actor_name, req)
 
         return self.__build_result(resp)
 
-    def __build_request(self, action: str, request: any):
+    def __build_request(self, action: str, request: any, async_mode: bool = False, pooled: bool = False):
         req: InvocationRequest = InvocationRequest()
         system = ActorSystem()
         system.name = self.actor_system
@@ -65,6 +66,8 @@ def __build_request(self, action: str, request: any):
         req.system.CopyFrom(system)
         req.actor.CopyFrom(actor)
         req.action_name = action
+        req.pooled = pooled
+        setattr(req, 'async', async_mode)
 
         if request != None:
             req.value.CopyFrom(pack(request))