@@ -266,15 +266,15 @@ type SyncLoginFailure uint64 // TODO enumerate possible values
266
266
// SetConnectionListener sets or overrides a previously set listener for a "connection" event.
267
267
func (client * SyncClient ) SetConnectionListener (callback syncConnectionListener ) error {
268
268
if callback == nil {
269
- C .obx_sync_listener_connect (client .cClient , nil , 0 )
269
+ C .obx_sync_listener_connect (client .cClient , nil , nil )
270
270
cCallbackUnregister (client .cCallbacks [cCallbackIndexConnection ])
271
271
} else {
272
272
if cbId , err := cCallbackRegister (cVoidCallback (func () {
273
273
callback ()
274
274
})); err != nil {
275
275
return err
276
276
} else {
277
- C .obx_sync_listener_connect (client .cClient , (* C .OBX_sync_listener_connect )(cVoidCallbackDispatchPtr ), cbId .cPtrArg ())
277
+ C .obx_sync_listener_connect (client .cClient , (* C .OBX_sync_listener_connect )(cVoidCallbackDispatchPtr ), cbId .cPtr ())
278
278
client .swapCallbackId (cCallbackIndexConnection , cbId )
279
279
}
280
280
}
@@ -284,15 +284,15 @@ func (client *SyncClient) SetConnectionListener(callback syncConnectionListener)
284
284
// SetDisconnectionListener sets or overrides a previously set listener for a "disconnection" event.
285
285
func (client * SyncClient ) SetDisconnectionListener (callback syncDisconnectionListener ) error {
286
286
if callback == nil {
287
- C .obx_sync_listener_disconnect (client .cClient , nil , 0 )
287
+ C .obx_sync_listener_disconnect (client .cClient , nil , nil )
288
288
cCallbackUnregister (client .cCallbacks [cCallbackIndexDisconnection ])
289
289
} else {
290
290
if cbId , err := cCallbackRegister (cVoidCallback (func () {
291
291
callback ()
292
292
})); err != nil {
293
293
return err
294
294
} else {
295
- C .obx_sync_listener_disconnect (client .cClient , (* C .OBX_sync_listener_disconnect )(cVoidCallbackDispatchPtr ), cbId .cPtrArg ())
295
+ C .obx_sync_listener_disconnect (client .cClient , (* C .OBX_sync_listener_disconnect )(cVoidCallbackDispatchPtr ), cbId .cPtr ())
296
296
client .swapCallbackId (cCallbackIndexDisconnection , cbId )
297
297
}
298
298
}
@@ -302,15 +302,15 @@ func (client *SyncClient) SetDisconnectionListener(callback syncDisconnectionLis
302
302
// SetLoginListener sets or overrides a previously set listener for a "login" event.
303
303
func (client * SyncClient ) SetLoginListener (callback syncLoginListener ) error {
304
304
if callback == nil {
305
- C .obx_sync_listener_login (client .cClient , nil , 0 )
305
+ C .obx_sync_listener_login (client .cClient , nil , nil )
306
306
cCallbackUnregister (client .cCallbacks [cCallbackIndexLogin ])
307
307
} else {
308
308
if cbId , err := cCallbackRegister (cVoidCallback (func () {
309
309
callback ()
310
310
})); err != nil {
311
311
return err
312
312
} else {
313
- C .obx_sync_listener_login (client .cClient , (* C .OBX_sync_listener_login )(cVoidCallbackDispatchPtr ), cbId .cPtrArg ())
313
+ C .obx_sync_listener_login (client .cClient , (* C .OBX_sync_listener_login )(cVoidCallbackDispatchPtr ), cbId .cPtr ())
314
314
client .swapCallbackId (cCallbackIndexLogin , cbId )
315
315
}
316
316
}
@@ -320,15 +320,15 @@ func (client *SyncClient) SetLoginListener(callback syncLoginListener) error {
320
320
// SetLoginFailureListener sets or overrides a previously set listener for a "login" event.
321
321
func (client * SyncClient ) SetLoginFailureListener (callback syncLoginFailureListener ) error {
322
322
if callback == nil {
323
- C .obx_sync_listener_login_failure (client .cClient , nil , 0 )
323
+ C .obx_sync_listener_login_failure (client .cClient , nil , nil )
324
324
cCallbackUnregister (client .cCallbacks [cCallbackIndexLoginFailure ])
325
325
} else {
326
326
if cbId , err := cCallbackRegister (cVoidUint64Callback (func (code uint64 ) {
327
327
callback (SyncLoginFailure (code ))
328
328
})); err != nil {
329
329
return err
330
330
} else {
331
- C .obx_sync_listener_login_failure (client .cClient , (* C .OBX_sync_listener_login_failure )(cVoidUint64CallbackDispatchPtr ), cbId .cPtrArg ())
331
+ C .obx_sync_listener_login_failure (client .cClient , (* C .OBX_sync_listener_login_failure )(cVoidUint64CallbackDispatchPtr ), cbId .cPtr ())
332
332
client .swapCallbackId (cCallbackIndexLoginFailure , cbId )
333
333
}
334
334
}
@@ -338,15 +338,15 @@ func (client *SyncClient) SetLoginFailureListener(callback syncLoginFailureListe
338
338
// SetCompletionListener sets or overrides a previously set listener for a "login" event.
339
339
func (client * SyncClient ) SetCompletionListener (callback syncCompletionListener ) error {
340
340
if callback == nil {
341
- C .obx_sync_listener_complete (client .cClient , nil , 0 )
341
+ C .obx_sync_listener_complete (client .cClient , nil , nil )
342
342
cCallbackUnregister (client .cCallbacks [cCallbackIndexCompletion ])
343
343
} else {
344
344
if cbId , err := cCallbackRegister (cVoidCallback (func () {
345
345
callback ()
346
346
})); err != nil {
347
347
return err
348
348
} else {
349
- C .obx_sync_listener_complete (client .cClient , (* C .OBX_sync_listener_complete )(cVoidCallbackDispatchPtr ), cbId .cPtrArg ())
349
+ C .obx_sync_listener_complete (client .cClient , (* C .OBX_sync_listener_complete )(cVoidCallbackDispatchPtr ), cbId .cPtr ())
350
350
client .swapCallbackId (cCallbackIndexCompletion , cbId )
351
351
}
352
352
}
@@ -356,7 +356,7 @@ func (client *SyncClient) SetCompletionListener(callback syncCompletionListener)
356
356
// SetServerTimeListener sets or overrides a previously set listener for a "login" event.
357
357
func (client * SyncClient ) SetServerTimeListener (callback syncTimeListener ) error {
358
358
if callback == nil {
359
- C .obx_sync_listener_server_time (client .cClient , nil , 0 )
359
+ C .obx_sync_listener_server_time (client .cClient , nil , nil )
360
360
cCallbackUnregister (client .cCallbacks [cCallbackIndexServerTime ])
361
361
} else {
362
362
if cbId , err := cCallbackRegister (cVoidInt64Callback (func (timestampNs int64 ) {
@@ -365,7 +365,7 @@ func (client *SyncClient) SetServerTimeListener(callback syncTimeListener) error
365
365
})); err != nil {
366
366
return err
367
367
} else {
368
- C .obx_sync_listener_server_time (client .cClient , (* C .OBX_sync_listener_server_time )(cVoidInt64CallbackDispatchPtr ), cbId .cPtrArg ())
368
+ C .obx_sync_listener_server_time (client .cClient , (* C .OBX_sync_listener_server_time )(cVoidInt64CallbackDispatchPtr ), cbId .cPtr ())
369
369
client .swapCallbackId (cCallbackIndexServerTime , cbId )
370
370
}
371
371
}
@@ -376,15 +376,15 @@ func (client *SyncClient) SetServerTimeListener(callback syncTimeListener) error
376
376
// SyncChange event is issued after a transaction is applied to the local database.
377
377
func (client * SyncClient ) SetChangeListener (callback syncChangeListener ) error {
378
378
if callback == nil {
379
- C .obx_sync_listener_change (client .cClient , nil , 0 )
379
+ C .obx_sync_listener_change (client .cClient , nil , nil )
380
380
cCallbackUnregister (client .cCallbacks [cCallbackIndexChange ])
381
381
} else {
382
382
if cbId , err := cCallbackRegister (cVoidConstVoidCallback (func (cChangeList unsafe.Pointer ) {
383
383
callback (cSyncChangeArrayToGo ((* C .OBX_sync_change_array )(cChangeList )))
384
384
})); err != nil {
385
385
return err
386
386
} else {
387
- C .obx_sync_listener_change (client .cClient , (* C .OBX_sync_listener_change )(cVoidConstVoidCallbackDispatchPtr ), cbId .cPtrArg ())
387
+ C .obx_sync_listener_change (client .cClient , (* C .OBX_sync_listener_change )(cVoidConstVoidCallbackDispatchPtr ), cbId .cPtr ())
388
388
client .swapCallbackId (cCallbackIndexChange , cbId )
389
389
}
390
390
}
0 commit comments