cross_framework_rpc_server_client_quickstart.py

1import cross
2import asyncio
3
4# Define a simple service
5class Greeter:
6    @cross.expose
7    async def say_hello(self, name: str) -> str:
8        return f"Hello, {name}! Welcome to Cross."
9
10async def main():
11    # 1. Start the server
12    server = cross.Server()
13    server.add_service(Greeter())
14    await server.listen("tcp://127.0.0.1:8080")
15    print("Server started on tcp://127.0.0.1:8080")
16
17    # 2. Create a client and connect
18    async with cross.Client("tcp://127.0.0.1:8080") as client:
19        # 3. Call the remote method
20        response = await client.call("Greeter.say_hello", name="Developer")
21        print(f"Response from server: {response}")
22
23    # Stop the server for this example
24    await server.stop()
25
26if __name__ == "__main__":
27    asyncio.run(main())