addUpdateListener method
void
addUpdateListener(})
override
Implementation
@override
void addUpdateListener(void Function(T? response) callback,
{void Function(String error)? onError, String? whereClause}) async {
try {
if (_rtUrl.isEmpty) _rtUrl = (await RTLookupService.lookup())!;
if (_rtUrl.isNotEmpty) {
await RTListener.subscribeForObjectsChanges<T>(
RTEventHandlers.UPDATED.toShortString(), _tableName, callback,
whereClause: whereClause);
} else {
if (kDebugMode) {
print('empty url');
}
throw ArgumentError.value(ExceptionMessage.noInternetConnection);
}
} catch (ex) {
onError!.call(ex.toString());
}
}