From 49ac2eb9b2d5abe300362e182357b35cf0f4f1ff Mon Sep 17 00:00:00 2001 From: ATATC Date: Mon, 15 Jul 2024 20:37:18 +0800 Subject: [PATCH] Supported passing the separators to the constructors. (#288) --- leads/comm/client/__init__.py | 5 +++-- leads/comm/server/__init__.py | 5 +++-- 2 files changed, 6 insertions(+), 4 deletions(-) diff --git a/leads/comm/client/__init__.py b/leads/comm/client/__init__.py index f64178ef..acce0ee9 100644 --- a/leads/comm/client/__init__.py +++ b/leads/comm/client/__init__.py @@ -2,14 +2,15 @@ from leads.comm.prototype import Callback -def create_client(port: int = 16900, callback: Callback = Callback()) -> Client: +def create_client(port: int = 16900, callback: Callback = Callback(), separator: bytes = b";") -> Client: """ Create a client service. :param port: the port to which the client connects :param callback: the callback methods + :param separator: the separator that splits messages into sentences :return: the client service """ - return Client(port, callback) + return Client(port, callback, separator) def start_client(server_address: str, target: Client = create_client(), parallel: bool = False) -> Client: diff --git a/leads/comm/server/__init__.py b/leads/comm/server/__init__.py index 8505aff1..81a7830f 100644 --- a/leads/comm/server/__init__.py +++ b/leads/comm/server/__init__.py @@ -2,14 +2,15 @@ from leads.comm.server.server import Server -def create_server(port: int = 16900, callback: Callback = Callback()) -> Server: +def create_server(port: int = 16900, callback: Callback = Callback(), separator: bytes = b";") -> Server: """ Create a server service. :param port: the port on which the server listens :param callback: the callback methods + :param separator: the separator that splits messages into sentences :return: the server service """ - return Server(port, callback) + return Server(port, callback, separator) def start_server(target: Server = create_server(), parallel: bool = False) -> Server: