Suffix listener function types with '_t' to indicate that they are 'types' in Python code

Author: Shubham

objectbox/c.py

@@ -1185,13 +1185,13 @@ class OBX_sync_msg_objects_builder(ctypes.Structure):
 OBX_sync_msg_objects_builder_p = ctypes.POINTER(OBX_sync_msg_objects_builder)
 
 # Define callback types for sync listeners
-OBX_sync_listener_connect = ctypes.CFUNCTYPE(None, ctypes.c_void_p)
-OBX_sync_listener_disconnect = ctypes.CFUNCTYPE(None, ctypes.c_void_p)
-OBX_sync_listener_login = ctypes.CFUNCTYPE(None, ctypes.c_void_p)
-OBX_sync_listener_login_failure = ctypes.CFUNCTYPE(None, ctypes.c_void_p, ctypes.c_int)  # arg, OBXSyncCode
-OBX_sync_listener_complete = ctypes.CFUNCTYPE(None, ctypes.c_void_p)
-OBX_sync_listener_error = ctypes.CFUNCTYPE(None, ctypes.c_void_p, ctypes.c_int)  # arg, OBXSyncError
-OBX_sync_listener_change = ctypes.CFUNCTYPE(None, ctypes.c_void_p, ctypes.POINTER(OBX_sync_change_array))
+OBX_sync_listener_connect_t = ctypes.CFUNCTYPE(None, ctypes.c_void_p)
+OBX_sync_listener_disconnect_t = ctypes.CFUNCTYPE(None, ctypes.c_void_p)
+OBX_sync_listener_login_t = ctypes.CFUNCTYPE(None, ctypes.c_void_p)
+OBX_sync_listener_login_failure_t = ctypes.CFUNCTYPE(None, ctypes.c_void_p, ctypes.c_int)  # arg, OBXSyncCode
+OBX_sync_listener_complete_t = ctypes.CFUNCTYPE(None, ctypes.c_void_p)
+OBX_sync_listener_error_t = ctypes.CFUNCTYPE(None, ctypes.c_void_p, ctypes.c_int)  # arg, OBXSyncError
+OBX_sync_listener_change_t = ctypes.CFUNCTYPE(None, ctypes.c_void_p, ctypes.POINTER(OBX_sync_change_array))
 OBX_sync_listener_server_time = ctypes.CFUNCTYPE(None, ctypes.c_void_p, ctypes.c_int64)
 OBX_sync_listener_msg_objects = ctypes.CFUNCTYPE(None, ctypes.c_void_p, ctypes.POINTER(OBX_sync_msg_objects))
 
@@ -1259,23 +1259,28 @@ class OBX_sync_msg_objects_builder(ctypes.Structure):
 # Listener Callbacks
 
 # void obx_sync_listener_connect(OBX_sync* sync, OBX_sync_listener_connect* listener, void* listener_arg);
-obx_sync_listener_connect = c_fn('obx_sync_listener_connect', None, [OBX_sync_p, OBX_sync_listener_connect, ctypes.c_void_p])
+obx_sync_listener_connect = c_fn('obx_sync_listener_connect', None,
+                                 [OBX_sync_p, OBX_sync_listener_connect_t, ctypes.c_void_p])
 
 # void obx_sync_listener_disconnect(OBX_sync* sync, OBX_sync_listener_disconnect* listener, void* listener_arg);
-obx_sync_listener_disconnect = c_fn('obx_sync_listener_disconnect', None, [OBX_sync_p, OBX_sync_listener_disconnect, ctypes.c_void_p])
+obx_sync_listener_disconnect = c_fn('obx_sync_listener_disconnect', None,
+                                    [OBX_sync_p, OBX_sync_listener_disconnect_t, ctypes.c_void_p])
 
 # void obx_sync_listener_login(OBX_sync* sync, OBX_sync_listener_login* listener, void* listener_arg);
-obx_sync_listener_login = c_fn('obx_sync_listener_login', None, [OBX_sync_p, OBX_sync_listener_login, ctypes.c_void_p])
+obx_sync_listener_login = c_fn('obx_sync_listener_login', None,
+                               [OBX_sync_p, OBX_sync_listener_login_t, ctypes.c_void_p])
 
 # void obx_sync_listener_login_failure(OBX_sync* sync, OBX_sync_listener_login_failure* listener, void* listener_arg);
-obx_sync_listener_login_failure = c_fn('obx_sync_listener_login_failure', None, [OBX_sync_p, OBX_sync_listener_login_failure, ctypes.c_void_p])
+obx_sync_listener_login_failure = c_fn('obx_sync_listener_login_failure', None,
+                                       [OBX_sync_p, OBX_sync_listener_login_failure_t, ctypes.c_void_p])
 
 # void obx_sync_listener_complete(OBX_sync* sync, OBX_sync_listener_complete* listener, void* listener_arg);
-obx_sync_listener_error = c_fn('obx_sync_listener_error', None, [OBX_sync_p, OBX_sync_listener_error, ctypes.c_void_p])
+obx_sync_listener_error = c_fn('obx_sync_listener_error', None,
+                               [OBX_sync_p, OBX_sync_listener_error_t, ctypes.c_void_p])
 
 # void obx_sync_listener_change(OBX_sync* sync, OBX_sync_listener_change* listener, void* listener_arg);
 obx_sync_listener_change = c_fn('obx_sync_listener_change', None,
-                                [OBX_sync_p, OBX_sync_listener_change, ctypes.c_void_p])
+                                [OBX_sync_p, OBX_sync_listener_change_t, ctypes.c_void_p])
 
 # Filter Variables
 

objectbox/sync.py

@@ -582,8 +582,8 @@ def set_login_listener(self, login_listener: SyncLoginListener):
             login_listener: The listener to receive login events.
         """
         self.__check_sync_ptr_not_null()
-        self.__c_login_listener = c.OBX_sync_listener_login(lambda arg: login_listener.on_logged_in())
-        self.__c_login_failure_listener = c.OBX_sync_listener_login_failure(
+        self.__c_login_listener = c.OBX_sync_listener_login_t(lambda arg: login_listener.on_logged_in())
+        self.__c_login_failure_listener = c.OBX_sync_listener_login_failure_t(
             lambda arg, sync_login_code: login_listener.on_login_failed(sync_login_code))
         c.obx_sync_listener_login(
             self.__c_sync_client_ptr,
@@ -603,8 +603,9 @@ def set_connection_listener(self, connection_listener: SyncConnectionListener):
             connection_listener: The listener to receive connection events.
         """
         self.__check_sync_ptr_not_null()
-        self.__c_connect_listener = c.OBX_sync_listener_connect(lambda arg: connection_listener.on_connected())
-        self.__c_disconnect_listener = c.OBX_sync_listener_disconnect(lambda arg: connection_listener.on_disconnected())
+        self.__c_connect_listener = c.OBX_sync_listener_connect_t(lambda arg: connection_listener.on_connected())
+        self.__c_disconnect_listener = c.OBX_sync_listener_disconnect_t(
+            lambda arg: connection_listener.on_disconnected())
         c.obx_sync_listener_connect(
             self.__c_sync_client_ptr,
             self.__c_connect_listener,
@@ -623,7 +624,7 @@ def set_error_listener(self, error_listener: SyncErrorListener):
             error_listener: The listener to receive error events.
         """
         self.__check_sync_ptr_not_null()
-        self.__c_error_listener = c.OBX_sync_listener_error(
+        self.__c_error_listener = c.OBX_sync_listener_error_t(
             lambda arg, sync_error_code: error_listener.on_error(sync_error_code))
         c.obx_sync_listener_error(
             self.__c_sync_client_ptr,
@@ -662,7 +663,7 @@ def c_change_callback(arg, sync_change_array_ptr):
                 ))
             change_listener.on_change(changes)
 
-        self.__c_change_listener = c.OBX_sync_listener_change(c_change_callback)
+        self.__c_change_listener = c.OBX_sync_listener_change_t(c_change_callback)
         c.obx_sync_listener_change(
             self.__c_sync_client_ptr,
             self.__c_change_listener,