Observe in real time

1// In your type declaration, declare a cancellable to hold onto the subscription
2var postsSubscription: AnyCancellable?
3
4// Then in the body of your code, subscribe to the publisher
5func subscribeToPosts() {
6    postsSubscription = Amplify.DataStore.publisher(for: Todo.self)
7        .sink {
8            if case let .failure(error) = $0 {
9                print("Subscription received error - \(error.localizedDescription)")
10            }
11        }
12        receiveValue: { changes in
13            // handle incoming changes
14            print("Subscription received mutation: \(changes)")
15        }
16}
17
18// Then, when you're finished observing, cancel the subscription
19func unsubscribeFromPosts() {
20    postsSubscription?.cancel()
21}

1// In your type declaration, declare a cancellable to hold onto the subscription
2var postsSubscription: AnyCancellable?
3
4func subscribeToPosts() {
5    let post = Post.keys
6    self.postsSubscription = Amplify.DataStore.observeQuery(
7            for: Post.self,
8            where: post.title.beginsWith("post") && post.rating > 10.0,
9            sort: .ascending(post.rating)
10        )
11        .sink { completed in
12            switch completed {
13            case .finished:
14                print("finished")
15            case .failure(let error):
16                print("Error \(error)")
17            }
18        } receiveValue: { querySnapshot in
19            print("[Snapshot] item count: \(querySnapshot.items.count), isSynced: \(querySnapshot.isSynced)")
20        }
21}
22
23// Then, when you're finished observing, cancel the subscription
24func unsubscribeFromPosts() {
25    postsSubscription?.cancel()
26}