ThePain/Swiftgram
1
0
Fork 0
mirror of https://github.com/Swiftgram/Telegram-iOS.git synced 2025-12-17 20:00:38 +00:00
Code Issues Packages Projects Releases Wiki Activity

syntax fixes

Browse Source
This commit is contained in:
overtake 2021-08-19 15:52:36 +03:00
parent db748e3aec
commit 59d9772f90
1 changed files with 9 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
submodules/Postbox/Sources/AccountManager.swift
View File

@ -245,7 +245,7 @@ final class AccountManagerImpl<Types: AccountManagerTypes> {
if !self.currentRecordOperations.isEmpty || !self.currentMetadataOperations.isEmpty { if !self.currentRecordOperations.isEmpty || !self.currentMetadataOperations.isEmpty {
for (view, pipe) in self.recordsViews.copyItems() { for (view, pipe) in self.recordsViews.copyItems() {
if view.replay(operations: self.currentRecordOperations, metadataOperations: self.currentMetadataOperations) { if view.replay(operations: self.currentRecordOperations, metadataOperations: self.currentMetadataOperations) {
pipe.putNext(AccountRecordsView(view)) pipe.putNext(AccountRecordsView<Types>(view))
} }
} }
} }
@ -253,7 +253,7 @@ final class AccountManagerImpl<Types: AccountManagerTypes> {
if !self.currentUpdatedSharedDataKeys.isEmpty { if !self.currentUpdatedSharedDataKeys.isEmpty {
for (view, pipe) in self.sharedDataViews.copyItems() { for (view, pipe) in self.sharedDataViews.copyItems() {
if view.replay(accountManagerImpl: self, updatedKeys: self.currentUpdatedSharedDataKeys) { if view.replay(accountManagerImpl: self, updatedKeys: self.currentUpdatedSharedDataKeys) {
pipe.putNext(AccountSharedDataView(view)) pipe.putNext(AccountSharedDataView<Types>(view))
} }
} }
} }
@ -287,7 +287,7 @@ final class AccountManagerImpl<Types: AccountManagerTypes> {
} }
fileprivate func accountRecords() -> Signal<AccountRecordsView<Types>, NoError> { fileprivate func accountRecords() -> Signal<AccountRecordsView<Types>, NoError> {
return self.transaction(ignoreDisabled: false, { transaction -> Signal<AccountRecordsView, NoError> in return self.transaction(ignoreDisabled: false, { transaction -> Signal<AccountRecordsView<Types>, NoError> in
return self.accountRecordsInternal(transaction: transaction) return self.accountRecordsInternal(transaction: transaction)
}) })
|> switchToLatest |> switchToLatest
@ -323,9 +323,9 @@ final class AccountManagerImpl<Types: AccountManagerTypes> {
let index = self.recordsViews.add((mutableView, pipe)) let index = self.recordsViews.add((mutableView, pipe))
let queue = self.queue let queue = self.queue
return (.single(AccountRecordsView(mutableView)) return (.single(AccountRecordsView<Types>(mutableView))
|> then(pipe.signal())) |> then(pipe.signal()))
|> `catch` { _ -> Signal<AccountRecordsView, NoError> in |> `catch` { _ -> Signal<AccountRecordsView<Types>, NoError> in
} }
|> afterDisposed { [weak self] in |> afterDisposed { [weak self] in
queue.async { queue.async {
@ -337,14 +337,14 @@ final class AccountManagerImpl<Types: AccountManagerTypes> {
} }
private func sharedDataInternal(transaction: AccountManagerModifier<Types>, keys: Set<ValueBoxKey>) -> Signal<AccountSharedDataView<Types>, NoError> { private func sharedDataInternal(transaction: AccountManagerModifier<Types>, keys: Set<ValueBoxKey>) -> Signal<AccountSharedDataView<Types>, NoError> {
let mutableView = MutableAccountSharedDataView(accountManagerImpl: self, keys: keys) let mutableView = MutableAccountSharedDataView<Types>(accountManagerImpl: self, keys: keys)
let pipe = ValuePipe<AccountSharedDataView<Types>>() let pipe = ValuePipe<AccountSharedDataView<Types>>()
let index = self.sharedDataViews.add((mutableView, pipe)) let index = self.sharedDataViews.add((mutableView, pipe))
let queue = self.queue let queue = self.queue
return (.single(AccountSharedDataView(mutableView)) return (.single(AccountSharedDataView<Types>(mutableView))
|> then(pipe.signal())) |> then(pipe.signal()))
|> `catch` { _ -> Signal<AccountSharedDataView, NoError> in |> `catch` { _ -> Signal<AccountSharedDataView<Types>, NoError> in
} }
|> afterDisposed { [weak self] in |> afterDisposed { [weak self] in
queue.async { queue.async {
@ -363,7 +363,7 @@ final class AccountManagerImpl<Types: AccountManagerTypes> {
let queue = self.queue let queue = self.queue
return (.single(NoticeEntryView(mutableView)) return (.single(NoticeEntryView(mutableView))
|> then(pipe.signal())) |> then(pipe.signal()))
|> `catch` { _ -> Signal<NoticeEntryView, NoError> in |> `catch` { _ -> Signal<NoticeEntryView<Types>, NoError> in
} }
|> afterDisposed { [weak self] in |> afterDisposed { [weak self] in
queue.async { queue.async {