diff --git a/example/spawn_example.py b/example/spawn_example.py index 4ba478e..aba6ad6 100644 --- a/example/spawn_example.py +++ b/example/spawn_example.py @@ -3,15 +3,14 @@ Licensed under the Apache License, Version 2.0. """ from spawn.sdk import Spawn -from example.joe import JoeActor +from example.joe import JoeActor from example.domain.domain_pb2 import Reply, Request -if __name__ == '__main__': - #request = Request() - #request.language = "erlang" - #Spawn.invoke("joe", "setLanguage", request, Reply) +if __name__ == "__main__": + request = Request() + request.language = "erlang" + # Spawn.invoke("joe", "setLanguage", request, Reply) - Spawn()\ - .port('8091')\ - .register_actor(JoeActor.entity)\ - .start() + spawn = Spawn() + spawn.port("8091").register_actor(JoeActor.entity).start() + spawn.invoke("vijay", "setLanguage", request, Reply) diff --git a/spawn/sdk.py b/spawn/sdk.py index 04f7953..a17bb92 100644 --- a/spawn/sdk.py +++ b/spawn/sdk.py @@ -65,7 +65,7 @@ def start(self): """Start the user function and HTTP Server.""" address = "{}:{}".format(self.__host, self.__port) - server = threading.Thread(target=self.__start_server, daemon=True, args=(action_handler,)) + server = threading.Thread(target=lambda: self.__start_server(action_handler)) logging.info("Starting Spawn on address %s", address) try: server.start() @@ -75,12 +75,14 @@ def start(self): except IOError as e: logging.error("Error on start Spawn %s", e.__cause__) - while True: - time.sleep(1) - def __register(self, actors: List[ActorEntity]): self.__actorController.register(actors) def __start_server(self, handler): - self.__app.register_blueprint(handler, url_prefix='/api/v1') - self.__app.run(host=self.__host, port=self.__port, use_reloader=False, debug=self.__is_debug_enable) \ No newline at end of file + self.__app.register_blueprint(handler, url_prefix="/api/v1") + self.__app.run( + host=self.__host, + port=self.__port, + use_reloader=False, + debug=self.__is_debug_enable, + )