The Client class provides a low-level TCP client that runs asynchronous read/write loops in a daemon thread. It exposes thread-safe methods for sending messages and closing connections from the main thread.
Constructor
Server hostname or IP address.
from repod import Client
client = Client(host="localhost", port=5071)
client.start_background()
Properties
(host, port) tuple for the remote server.
host, port = client.address
print(f"Connecting to {host}:{port}")
Methods
start_background
def start_background() -> None
client = Client("localhost", 5071)
client.start_background()
send
def send(data: dict[str, Any]) -> int
Message dictionary. Should contain an action key.
Number of bytes queued, or 0 if disconnected.
bytes_sent = client.send({"action": "move", "x": 10, "y": 20})
if bytes_sent == 0:
print("Client is disconnected")
close
Close the connection. Safe to call from any thread. Subsequent calls are no-ops.
Full Example
import time
from repod import Client
client = Client("localhost", 5071)
client.start_background()
# Send messages
client.send({"action": "login", "username": "alice"})
client.send({"action": "chat", "text": "Hello world!"})
# Keep the main thread alive
time.sleep(1.0)
# Close when done
client.close()
Notes
- The client runs an asyncio event loop in a background daemon thread, allowing the main application loop to remain fully synchronous.
- Messages are queued and sent asynchronously via the background thread.
- The
send() method is thread-safe and can be called from any thread.
- For most use cases, consider using ConnectionListener instead, which provides a higher-level interface.