Skip to content

Commit

Permalink
Merge pull request #1068 from WalletConnect/list-refresh
Browse files Browse the repository at this point in the history
[WalletApp, Notify] List refresh
  • Loading branch information
llbartekll authored Aug 30, 2023
2 parents d0d5f62 + 0170fb4 commit 42e42d8
Showing 1 changed file with 14 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -20,7 +20,18 @@ final class PushMessagesPresenter: ObservableObject {
defer { setupInitialState() }
self.interactor = interactor
self.router = router
setUpMessagesRefresh()
}

private func setUpMessagesRefresh() {
Timer.publish(every: 10.0, on: .main, in: .default)
.autoconnect()
.sink(receiveValue: { [weak self] _ in
guard let self = self else { return }
self.pushMessages = self.interactor.getPushMessages()
}).store(in: &disposeBag)
}


func deletePushMessage(at indexSet: IndexSet) {
if let index = indexSet.first {
Expand Down Expand Up @@ -50,8 +61,9 @@ private extension PushMessagesPresenter {

interactor.messagesPublisher
.receive(on: DispatchQueue.main)
.sink { [unowned self] messages in
pushMessages = interactor.getPushMessages()
.sink { [weak self] messages in
guard let self = self else { return }
self.pushMessages = self.interactor.getPushMessages()
}
.store(in: &disposeBag)
}
Expand Down

0 comments on commit 42e42d8

Please sign in to comment.