From ad22b3621af058a0535ab74a9a36a0cecb57f9a4 Mon Sep 17 00:00:00 2001
From: zhaohe <h_zhaohe@163.com>
Date: Thu, 4 Jan 2024 20:30:39 +0800
Subject: [PATCH] update

---
 xsync.hpp | 26 ++++++++++----------------
 1 file changed, 10 insertions(+), 16 deletions(-)

diff --git a/xsync.hpp b/xsync.hpp
index 46662fa..ccc34f7 100644
--- a/xsync.hpp
+++ b/xsync.hpp
@@ -30,24 +30,11 @@ class XsyncNetAdd {
   uint32_t port;
 };
 
-class I_XSUDPListener {
- public:
-  typedef function<void(XsyncNetAdd& from, uint8_t* data, size_t length)> onMessage_t;
 
+class I_XSUDP {
  public:
-  /**
-   * @brief 初始化UDP
-   *
-   * @param ip localip default 0
-   * @param localport localport
-   * @param onMessage UDP消息监听
-   * @return int
-   */
-  virtual xs_error_code_t initialize(string ip, int localport, onMessage_t onMessage) = 0;
-  virtual ~I_XSUDPListener() {}
-};
+  typedef function<void(XsyncNetAdd& from, uint8_t* data, size_t length)> onMessage_t;
 
-class I_XSUDP {
  public:
   /**
    * @brief 初始化UDP
@@ -80,12 +67,19 @@ class I_XSUDP {
    */
   virtual xs_error_code_t receive(char* data, int32_t& length, XsyncNetAdd& from, int overtimems) = 0;
 
+  /**
+   * @brief 开始接收UDP消息
+   * 
+   * @param onMessage 
+   * @return xs_error_code_t 
+   */
+  virtual xs_error_code_t startReceive(onMessage_t onMessage) = 0;
+
   virtual ~I_XSUDP() {}
 };
 
 class I_XSyncUDPFactory {
  public:
-  virtual shared_ptr<I_XSUDPListener> createXSUDPListener() = 0;
   virtual shared_ptr<I_XSUDP>         createXSUDP()         = 0;
 };