Hello, This is more of a best practice question, in Flutter I retrieve some documents into a list when the user opens the app. When the user clicks on a document it goes to a details page. I only want to listen to realtime events for that specific document, while user is viewing. Where is the best place to subscribe to the realtime events of this document? Should it be in the initState or soon as the user clicks the item in the list? also I'm assuming on this page I should close the subscription in the dispose() method. Thanks for any suggestions.
I think the best way would be
init in initState as this is the best way to interact with the state
And close it in the dispose method
This way you can assure you will listened to realtime event only and when it needed
ya, this probably makes sense. @djcali, make sure you're using a new Realtime instance in this details page to make sure there's no race condition problem
Oh man, I was wondering why I was having an issue with a bunch of realtime connections. It was doubling up. Thanks!
Works perfectly. Thanks for all the help.
Hi, I have one issue. I'm not sure the correct way to resubscribe when it gets disposed by Flutter randomly. Here is what I have so far. I'm getting error trying to access a deactivated widget, because the way i'm resubscribing.
super.initState();
subscribe();
}
late RealtimeSubscription subscription;
void subscribe() {
debugPrint('Subscribing to realtime');
final client = ref.read(appwriteClientProvider);
final realtime = Realtime(client);
subscription = realtime.subscribe([
'databases.default.collections.events.documents.642ba977cff76a18a36c'
]);
subscription.stream.listen((response) {
print(response);
}, onDone: () {
subscribe();
});
}
@override
void dispose() {
subscription.close();
super.dispose();
} ```
What is the error you're getting
When I leave the Details page the Dispose() method fires then the onDone of the listen function fires because I'm trying to resubscribe. I want this to work unless I'm leaving the page. Hope this makes sense.
Got you What I usually do in this use-case is creating a flag that I will update in the dispose method like this.
private _isDone = false;
void initState() {
super.initState();
subscribe();
}
late RealtimeSubscription subscription;
void subscribe() {
debugPrint('Subscribing to realtime');
final client = ref.read(appwriteClientProvider);
final realtime = Realtime(client);
subscription = realtime.subscribe([
'databases.default.collections.events.documents.642ba977cff76a18a36c'
]);
subscription.stream.listen((response) {
print(response);
}, onDone: () {
if(!_isDone)
subscribe();
});
}
@override
void dispose() {
_isDone = true;
subscription.close();
super.dispose();
}
I think I tried something like this but I wasn't using a private variable. Going to try your way and report back. Thanks!
Worked perfectly. Thanks!
Perfect 😄
[SOLVED] Realtime in Flutter
Recommended threads
- Custom Topic sent from Function (with sc...
Can I send a message on a custom topic? So clients can subscribe to them?
- CORS error only on tables db api After u...
I've recently updated my self hosted appwrite instance to the 1.8.0 and updated my frontend with the tables db apis but strangely, even if I'm able to log in, g...
- [SOLVED] Access ExecutionStatus of a fun...
I am calling a cloud function from the newest Flutter SDK 20.2.1with the `xasync: false` flag and get the result, but the `execution.status` is not a String and...