{"id":327009,"date":"2022-01-10T08:43:30","date_gmt":"2022-01-10T08:43:30","guid":{"rendered":"http:\/\/savepearlharbor.com\/?p=327009"},"modified":"-0001-11-30T00:00:00","modified_gmt":"-0001-11-29T21:00:00","slug":"","status":"publish","type":"post","link":"https:\/\/savepearlharbor.com\/?p=327009","title":{"rendered":"<span>Kotlin Multiplatform. \u0420\u0430\u0431\u043e\u0442\u0430\u0435\u043c \u0441 \u0430\u0441\u0438\u043d\u0445\u0440\u043e\u043d\u043d\u043e\u0441\u0442\u044c\u044e \u043d\u0430 \u0441\u0442\u043e\u0440\u043e\u043d\u0435 iOS. Publishers, async\/await<\/span>"},"content":{"rendered":"<div><\/div>\n<div id=\"post-content-body\" class=\"article-formatted-body article-formatted-body_version-2\">\n<div xmlns=\"http:\/\/www.w3.org\/1999\/xhtml\">\n<figure class=\"full-width\"><img decoding=\"async\" src=\"\/img\/image-loader.svg\" height=\"348\" data-src=\"https:\/\/habrastorage.org\/getpro\/habr\/upload_files\/2cf\/b67\/acc\/2cfb67acc3544182a9edc4a347861560.png\" data-width=\"640\"\/><figcaption><\/figcaption><\/figure>\n<p><em>\u0412\u0441\u0435\u043c \u0434\u043e\u0431\u0440\u043e\u0433\u043e \u0432\u0440\u0435\u043c\u0435\u043d\u0438 \u0441\u0443\u0442\u043e\u043a! \u0421 \u0432\u0430\u043c\u0438 \u0410\u043d\u043d\u0430 \u0416\u0430\u0440\u043a\u043e\u0432\u0430, \u0432\u0435\u0434\u0443\u0449\u0438\u0439 \u0440\u0430\u0437\u0440\u0430\u0431\u043e\u0442\u0447\u0438\u043a \u043a\u043e\u043c\u043f\u0430\u043d\u0438\u0438 Usetech. \u041f\u0440\u043e\u0434\u043e\u043b\u0436\u0430\u0435\u043c \u0433\u043e\u0432\u043e\u0440\u0438\u0442\u044c \u043f\u0440\u043e Kotlin Multiplatform \u0438 \u0440\u0430\u0431\u043e\u0442\u0443 \u0441 \u0430\u0441\u0438\u043d\u0445\u0440\u043e\u043d\u043d\u044b\u043c\u0438 \u0444\u0443\u043d\u043a\u0446\u0438\u044f\u043c\u0438. \u0412 \u044d\u0442\u043e\u0439 \u0441\u0442\u0430\u0442\u044c\u0435 \u043c\u044b \u0431\u0443\u0434\u0435\u043c \u0440\u0430\u0441\u0441\u043c\u0430\u0442\u0440\u0438\u0432\u0430\u0442\u044c, \u043a\u0430\u043a \u043c\u043e\u0436\u043d\u043e \u0443\u0434\u043e\u0431\u043d\u043e \u043f\u043e\u0434\u043a\u043b\u044e\u0447\u0430\u0442\u044c Kotlin \u043e\u0431\u0449\u0438\u0439 \u043a\u043e\u0434 \u043d\u0430 \u0441\u0442\u043e\u0440\u043e\u043d\u0435 iOS, \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u0443\u044f \u0432\u043e\u0437\u043c\u043e\u0436\u043d\u043e\u0441\u0442\u0438 Swift. \u0410 \u0438\u043c\u0435\u043d\u043d\u043e, \u043a\u0430\u043a \u0440\u0430\u0431\u043e\u0442\u0430\u0442\u044c \u0441 Combine Publishers \u0438 \u043d\u043e\u0432\u044b\u043c async\/await.<\/em> <\/p>\n<p>\u041a\u043e\u043d\u0446\u0435\u043f\u0446\u0438\u044f Kotlin Multiplatform \u043f\u043e\u0437\u0432\u043e\u043b\u044f\u0435\u0442 \u043d\u0430\u043c \u0441\u0434\u0435\u043b\u0430\u0442\u044c \u043a\u043e\u0434 \u043c\u0430\u043a\u0441\u0438\u043c\u0430\u043b\u044c\u043d\u043e \u043e\u0431\u0449\u0438\u043c, \u0442.\u0435 \u0432\u044b\u043d\u0435\u0441\u0442\u0438 \u043f\u0440\u0430\u043a\u0442\u0438\u0447\u0435\u0441\u043a\u0438 \u0432\u0441\u0435 \u0432 \u043e\u0431\u0449\u0443\u044e \u0447\u0430\u0441\u0442\u044c. <\/p>\n<p>\u0415\u0441\u043b\u0438 \u043d\u0430 \u0441\u0442\u043e\u0440\u043e\u043d\u0435 common, \u043c\u044b \u043e\u043f\u0435\u0440\u0438\u0440\u0443\u0435\u043c \u043a\u043e\u0440\u0443\u0442\u0438\u043d\u0430\u043c\u0438 \u0438 suspend \u0444\u0443\u043d\u043a\u0446\u0438\u044f\u043c\u0438:<\/p>\n<pre><code class=\"kotlin\">suspend fun getNewsList():ContentResponse&lt;NewsList>{ return networkClient.request(Request(url = NEWS_LIST))  }<\/code><\/pre>\n<p>\u0422\u043e \u043d\u0430 \u0441\u0442\u043e\u0440\u043e\u043d\u0435 iOS \u043f\u0440\u043e\u0435\u043a\u0442\u0430 \u043d\u0430\u0442\u0438\u0432\u043d\u043e\u0433\u043e \u0431\u043b\u0430\u0433\u043e\u0434\u0430\u0440\u044f \u043f\u043e\u0434\u0434\u0435\u0440\u0436\u043a\u0435 interop Kotlin\/Obj-C \u0441 \u0432\u0435\u0440\u0441\u0438\u0438 Kotlin 1.4 suspend \u0444\u0443\u043d\u043a\u0446\u0438\u0438 \u043f\u0440\u0435\u043e\u0431\u0440\u0430\u0437\u0443\u044e\u0442\u0441\u044f \u0432 \u0444\u0443\u043d\u043a\u0446\u0438\u0438 \u0441 completion handler:<\/p>\n<pre><code class=\"swift\">- (void)getNewsListWithCompletionHandler:(void (^)(SharedContentResponse&lt;SharedNewsList *> * _Nullable, NSError * _Nullable))completionHandler __attribute__((swift_name(\"getNewsList(completionHandler:)\")));  \/\/Swift newsService.getNewsList(completionHandler: { response, error in    if let data = response.content?.articles {     \/\/...     }                                                                                         }<\/code><\/pre>\n<p>\u0414\u0430\u043b\u0435\u0435 \u043c\u044b \u043c\u043e\u0436\u0435\u043c \u0432 \u044d\u0442\u043e\u043c \u0431\u043b\u043e\u043a\u0435 \u043b\u0438\u0431\u043e \u0432\u044b\u0437\u0432\u0430\u0442\u044c \u0432\u044b\u0432\u043e\u0434 \u0434\u0430\u043d\u043d\u044b\u0445, \u043b\u0438\u0431\u043e \u0432\u044b\u043f\u043e\u043b\u043d\u0435\u043d\u0438\u0435 \u043a\u0430\u043a\u043e\u0433\u043e-\u0442\u043e \u0441\u043b\u0435\u0434\u0443\u044e\u0449\u0435\u0433\u043e \u043c\u0435\u0442\u043e\u0434\u0430. \u0412\u0441\u0435 \u0441\u0442\u0430\u043d\u0434\u0430\u0440\u0442\u043d\u043e \u0438 \u043f\u0440\u043e\u0441\u0442\u043e. <br \/>\u041e\u0434\u043d\u0430\u043a\u043e, \u043d\u0435 \u0432\u0441\u0435 \u043b\u044e\u0431\u044f\u0442 \u043f\u0440\u043e\u0441\u0442\u043e\u0439 \u0441\u0438\u043d\u0442\u0430\u043a\u0441\u0438\u0441 completion handler. \u0410 \u0435\u0449\u0435 \u043c\u044b \u043f\u0440\u0435\u043a\u0440\u0430\u0441\u043d\u043e \u0437\u043d\u0430\u0435\u043c, \u0447\u0442\u043e \u0435\u0441\u043b\u0438 \u0438\u043c\u0438 \u0437\u043b\u043e\u0443\u043f\u043e\u0442\u0440\u0435\u0431\u043b\u044f\u0442\u044c, \u043c\u043e\u0436\u043d\u043e \u043b\u0435\u0433\u043a\u043e \u043f\u043e\u043f\u0430\u0441\u0442\u044c \u0432 \u0441\u0438\u0442\u0443\u0430\u0446\u0438\u044e callback hell \u0438 \u043f\u043e\u0442\u0435\u0440\u044f\u0442\u044c \u0447\u0438\u0442\u0430\u0431\u0435\u043b\u044c\u043d\u043e\u0441\u0442\u044c \u0438 \u0447\u0438\u0441\u0442\u043e\u0442\u0443 \u043a\u043e\u0434\u0430. <\/p>\n<p>\u0422\u0430\u043a\u0436\u0435 \u043d\u0435 \u0441\u0442\u043e\u0438\u0442 \u0437\u0430\u0431\u044b\u0432\u0430\u0442\u044c, \u0447\u0442\u043e \u0432 \u0437\u0430\u0432\u0438\u0441\u0438\u043c\u043e\u0441\u0442\u0438 \u043e\u0442 \u043f\u043e\u0441\u0442\u0430\u0432\u043b\u0435\u043d\u043d\u043e\u0439 \u0437\u0430\u0434\u0430\u0447\u0438 \u0443 \u043d\u0430\u0441 \u043c\u043e\u0433\u0443\u0442 \u0431\u044b\u0442\u044c \u043d\u0435 \u0442\u043e\u043b\u044c\u043a\u043e \u043e\u0431\u043e\u0431\u0449\u0430\u0435\u043c\u044b\u0435 \u043c\u0435\u0442\u043e\u0434\u044b.  \u041a\u043e\u0434 \u043f\u043b\u0430\u0442\u0444\u043e\u0440\u043c\u0435\u043d\u043d\u044b\u0445 \u043f\u0440\u043e\u0435\u043a\u0442\u043e\u0432 \u0443 \u043d\u0430\u0441 \u043c\u043e\u0436\u0435\u0442 \u0431\u044b\u0442\u044c \u043d\u0435 \u0438\u0434\u0435\u043d\u0442\u0438\u0447\u0435\u043d, \u043f\u043e\u044d\u0442\u043e\u043c\u0443 \u043d\u0435\u043b\u044c\u0437\u044f \u0438\u0441\u043a\u043b\u044e\u0447\u0430\u0442\u044c \u043b\u043e\u0433\u0438\u043a\u0438 \u0441\u0443\u0433\u0443\u0431\u043e \u043d\u0430\u0442\u0438\u0432\u043d\u043e\u0439, \u0432\u044b\u0437\u043e\u0432\u044b \u043a\u043e\u0442\u043e\u0440\u043e\u0439 \u043c\u044b \u043c\u043e\u0436\u0435\u043c \u0441\u043e\u0447\u0435\u0442\u0430\u0442\u044c \u0441 \u0432\u044b\u0437\u043e\u0432\u0430\u043c\u0438 \u043b\u043e\u0433\u0438\u043a\u0438 \u0438\u0437 \u043e\u0431\u0449\u0435\u0433\u043e \u043c\u043e\u0434\u0443\u043b\u044f. \u0427\u0442\u043e \u0432\u043f\u043e\u043b\u043d\u0435 \u043b\u043e\u0433\u0438\u0447\u043d\u043e. \u041f\u043e\u044d\u0442\u043e\u043c\u0443 \u0432\u043f\u043e\u043b\u043d\u0435 \u043d\u043e\u0440\u043c\u0430\u043b\u044c\u043d\u043e, \u0447\u0442\u043e \u043c\u044b \u0440\u0435\u0448\u0438\u043c \u043f\u0440\u0438\u043c\u0435\u043d\u0438\u0442\u044c \u0437\u0434\u0435\u0441\u044c \u0434\u043e\u0441\u0442\u0443\u043f\u043d\u044b\u0435 \u043f\u043e\u0434\u0445\u043e\u0434\u044b \u043a\u043e\u043d\u043a\u0440\u0435\u0442\u043d\u043e\u0439 \u043f\u043b\u0430\u0442\u0444\u043e\u0440\u043c\u044b. <\/p>\n<p>\u041f\u043e\u043f\u0440\u043e\u0431\u0443\u0435\u043c \u0441\u0434\u0435\u043b\u0430\u0442\u044c \u043d\u0430\u0448 Kotlin \u043a\u043e\u0434 \u0441\u043e\u0432\u043c\u0435\u0441\u0442\u0438\u043c\u044b\u043c \u0441 Combine Publishers. \u0414\u043b\u044f \u044d\u0442\u043e\u0433\u043e \u043f\u0440\u0435\u0432\u0440\u0430\u0442\u0438\u043c \u0432\u044b\u0437\u043e\u0432 \u043d\u0430\u0448\u0435\u0439 suspend \u0444\u0443\u043d\u043a\u0446\u0438\u0438 \u0432 AnyPublisher \u0441 \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u043d\u0438\u0435\u043c Future Deferred \u0438 Promise. <\/p>\n<pre><code class=\"swift\"> func getNewsList()-> AnyPublisher&lt;[NewsItem], Error> {         return Deferred {             Future { promise in                 self.getNewsList { response, error in                     if let data = response?.content?.articles {                         promise(.success(data))                     }                     if let error = response?.errorResponse {                         promise(.failure(CustomError(error: error.message)))                     }                     if let error = error {                         promise(.failure(error))                     }                 }             }                      }.eraseToAnyPublisher()<\/code><\/pre>\n<p>\u0414\u043b\u044f \u0443\u0434\u043e\u0431\u0441\u0442\u0432\u0430 \u043c\u043e\u0436\u043d\u043e \u0434\u0430\u0436\u0435 \u0432\u044b\u043d\u0435\u0441\u0442\u0438 \u0432\u044b\u0437\u043e\u0432 \u043c\u0435\u0442\u043e\u0434\u0430 \u0432 extension \u0441\u0435\u0440\u0432\u0438\u0441\u0430, \u043e\u0441\u0443\u0449\u0435\u0441\u0442\u0432\u043b\u044f\u044e\u0449\u0435\u0433\u043e \u0437\u0430\u043f\u0440\u043e\u0441:<\/p>\n<pre><code class=\"swift\">extension NewsService {          func getNewsList()-> AnyPublisher&lt;[NewsItem], Error> {         return Deferred {             Future { promise in              \/\/...                    }         }     }<\/code><\/pre>\n<p>\u0412\u044b\u0437\u043e\u0432 \u0432 \u043a\u043e\u0434\u0435 \u043d\u0430\u0448\u0435\u0433\u043e ObservableObject (\u0435\u0441\u043b\u0438 \u043c\u044b \u0433\u043e\u0432\u043e\u0440\u0438\u043c \u043f\u0440\u043e SwiftUI) \u0438\u043b\u0438 \u0434\u0440\u0443\u0433\u043e\u0439 \u0447\u0430\u0441\u0442\u0438 \u043b\u043e\u0433\u0438\u043a\u0438 \u0431\u0443\u0434\u0435\u0442 \u0430\u0431\u0441\u043e\u043b\u044e\u0442\u043d\u043e \u0442\u0430\u043a\u0438\u043c \u0436\u0435, \u043a\u0430\u043a \u0438 \u0432 \u0434\u0440\u0443\u0433\u0438\u0445 \u0441\u043b\u0443\u0447\u0430\u044f\u0445 \u0440\u0430\u0431\u043e\u0442\u044b \u0441 Publishers:<\/p>\n<pre><code class=\"swift\">func loadData() {      let _ =  newsService.getNewsList().sink { result in             switch result {             case .failure(let error):                 print(error.localizedDescription)             default:                 break             }         } receiveValue: { data in             self.items = [NewsItem]()             self.items.append(contentsOf: data)         }.store(in: &amp;store)      }<\/code><\/pre>\n<p>\u0427\u0442\u043e \u0436, \u043f\u043e\u043a\u0430 \u044d\u0442\u043e \u0432\u044b\u0433\u043b\u044f\u0434\u0438\u0442, \u043a\u0430\u043a \u043f\u0435\u0440\u0435\u043d\u043e\u0441 \u0440\u0435\u0448\u0435\u043d\u0438\u044f \u0434\u043b\u044f \u0440\u0430\u0431\u043e\u0442\u044b \u0441 Combine. \u041e\u0441\u043e\u0431\u043e\u0433\u043e \u043f\u0440\u043e\u0444\u0438\u0442\u0430 \u043d\u0435 \u0447\u0443\u0432\u0441\u0442\u0432\u0443\u0435\u0442\u0441\u044f. \u0422\u0435\u043c \u0431\u043e\u043b\u0435\u0435, \u0435\u0441\u043b\u0438 \u043f\u0440\u0435\u0434\u0441\u0442\u0430\u0432\u0438\u0442\u044c, \u0447\u0442\u043e \u043d\u0430\u043c \u043f\u0440\u0438\u0434\u0435\u0442\u0441\u044f \u043e\u0431\u0435\u0440\u043d\u0443\u0442\u044c \u0432 Publisher \u043a\u0430\u0436\u0434\u044b\u0439 \u043c\u0435\u0442\u043e\u0434, \u043a\u043e\u0442\u043e\u0440\u044b\u0439 \u043c\u044b \u0431\u0443\u0434\u0435\u043c \u0432\u044b\u0437\u044b\u0432\u0430\u0442\u044c \u043d\u0430 \u0441\u0442\u043e\u0440\u043e\u043d\u0435 iOS. <br \/>\u041d\u0430\u0434\u043e \u043a\u0430\u043a-\u0442\u043e \u043e\u0431\u043e\u0431\u0449\u0438\u0442\u044c.<br \/>\u041c\u043e\u0436\u043d\u043e \u043f\u043e\u043f\u0440\u043e\u0431\u043e\u0432\u0430\u0442\u044c \u0441\u0434\u0435\u043b\u0430\u0442\u044c \u0441\u0432\u043e\u0435\u043e\u0431\u0440\u0430\u0437\u043d\u044b\u0439 \u043c\u0435\u043d\u0435\u0434\u0436\u0435\u0440 \u0437\u0430\u0434\u0430\u0447 \u043d\u0430 \u0441\u0442\u043e\u0440\u043e\u043d\u0435 \u043e\u0431\u0449\u0435\u0433\u043e KMM \u043a\u043e\u0434\u0430, \u043d\u043e \u0432 \u0431\u043e\u043b\u044c\u0448\u0438\u043d\u0441\u0442\u0432\u0435 \u0441\u043b\u0443\u0447\u0430\u0435\u0432 \u044d\u0442\u043e \u0431\u0430\u043d\u0430\u043b\u044c\u043d\u044b\u0439 \u043e\u0432\u0435\u0440\u0438\u043d\u0436\u0435\u043d\u0435\u0440\u0438\u043d\u0433. \u041f\u043e\u043f\u0440\u043e\u0431\u0443\u0435\u043c \u043f\u043e\u0439\u0442\u0438 \u0447\u0435\u0440\u0435\u0437 Kotlin Flows, \u043a\u043e\u0442\u043e\u0440\u044b\u0435 \u043c\u044b \u043c\u043e\u0436\u0435\u043c \u043f\u0440\u0435\u0434\u0441\u0442\u0430\u0432\u0438\u0442\u044c \u0432 \u043e\u0431\u0449\u0435\u043c \u0432\u0438\u0434\u0435 \u043a\u0430\u043a Flow&lt;T>.<\/p>\n<p>\u041d\u0430 \u0441\u0442\u043e\u0440\u043e\u043d\u0435 Kotlin Multiplatform \u0440\u0430\u0431\u043e\u0442\u0430 \u0441 Flow \u0432\u044b\u0433\u043b\u044f\u0434\u0438\u0442 \u0442\u0430\u043a:<\/p>\n<pre><code class=\"kotlin\">\/\/ViewModel  val newsFlow = MutableStateFlow&lt;NewsList?>(null)  fun loadData() {         scope.launch {            val result =  newsService.getNewsList()             newsFlow.value = result.content         }     }<\/code><\/pre>\n<p>\u0414\u043b\u044f \u0430\u043d\u0434\u0440\u043e\u0438\u0434 \u043f\u043e\u043b\u0443\u0447\u0435\u043d\u0438\u0435 \u0434\u0430\u043d\u043d\u044b\u0445 c Flow \u0438\u0434\u0435\u0442 \u043d\u0430\u0442\u0438\u0432\u043d\u043e \u0438 \u043f\u0440\u043e\u0441\u0442\u043e, \u043d\u0430\u043c \u0434\u043e\u0441\u0442\u0430\u0442\u043e\u0447\u043d\u043e \u043f\u043e\u0434\u043f\u0438\u0441\u0430\u0442\u044c\u0441\u044f \u043d\u0430 \u0441\u043e\u0431\u044b\u0442\u0438\u0435:<\/p>\n<pre><code class=\"kotlin\"> lifecycleScope.launch {             repeatOnLifecycle(Lifecycle.State.STARTED) {                 viewModel.newsList.collect {                     setupNews(it)                 }             }          }<\/code><\/pre>\n<p>\u0423\u0441\u043b\u043e\u0432\u043d\u043e \u043f\u0440\u043e\u0441\u0442\u043e. \u0414\u043b\u044f iOS \u044d\u0442\u043e suspend \u0444\u0443\u043d\u043a\u0446\u0438\u044f, \u043a\u043e\u0442\u043e\u0440\u0430\u044f \u0442\u0440\u0435\u0431\u0443\u0435\u0442 \u0441\u0432\u043e\u0438 \u043f\u0430\u0440\u0430\u043c\u0435\u0442\u0440\u044b, \u043e\u0434\u043d\u0438\u043c \u0438\u0437 \u043a\u043e\u0442\u043e\u0440\u044b\u0445 \u044f\u0432\u043b\u044f\u0435\u0442\u0441\u044f \u0441\u043f\u0435\u0446\u0438\u0430\u043b\u044c\u043d\u044b\u0439 \u043a\u043e\u043b\u043b\u0435\u043a\u0442\u043e\u0440 Kotlinx_coroutines_coreFlowCollector:<\/p>\n<pre><code class=\"swift\">typealias Collector = Kotlinx_coroutines_coreFlowCollector  class Observer: Collector {     let callback:(Any?) -> Void          init(callback: @escaping (Any?) -> Void) {         self.callback = callback     }          func emit(value: Any?, completionHandler: @escaping (KotlinUnit?, Error?) -> Void) {         callback(value)         completionHandler(KotlinUnit(), nil)     } }<\/code><\/pre>\n<p>\u041f\u043e\u044d\u0442\u043e\u043c\u0443 \u043f\u043e\u0434\u043f\u0438\u0441\u043a\u0430 \u0443 \u043d\u0430\u0441 \u0431\u0443\u0434\u0435\u0442 \u0432\u044b\u0433\u043b\u044f\u0434\u0435\u0442\u044c \u043d\u0435\u043c\u043d\u043e\u0433\u043e \u043f\u043e-\u0434\u0440\u0443\u0433\u043e\u043c\u0443:<\/p>\n<pre><code class=\"kotlin\">lazy var collector: Observer = {         let collector = Observer {value in             if let value = value as? NewsList {                 let data = value.articles                 self.processNews(data: data)             }         }         return collector     }()    lazy var newsViewModel: NewsViewModel = {         let newsViewModel =  NewsViewModel()         newsViewModel.newsFlow.collect(collector: self.collector,                                         completionHandler: {_,_ in })         return newsViewModel     }()     <\/code><\/pre>\n<p>\u0422\u0430\u043a\u0436\u0435 \u043c\u043e\u0436\u043d\u043e \u0443\u043f\u0440\u043e\u0441\u0442\u0438\u0442\u044c \u0438 \u043e\u0431\u043e\u0431\u0449\u0438\u0442\u044c \u0432\u044b\u0437\u043e\u0432 \u0441 \u043f\u043e\u043c\u043e\u0449\u044c\u044e \u043e\u0431\u0435\u0440\u0442\u043a\u0438, \u043a\u043e\u0442\u043e\u0440\u0430\u044f \u0432\u043d\u0443\u0442\u0440\u0438 \u0431\u0443\u0434\u0435\u0442 \u0440\u0430\u0431\u043e\u0442\u0430\u0442\u044c \u0441\u043e \u0441\u0432\u043e\u0438\u043c Coroutine scope:<\/p>\n<pre><code class=\"swift\">class AnyFlow&lt;T>(source: Flow&lt;T>): Flow&lt;T> by source {     fun collect(onEach: (T) -> Unit,                  onCompletion: (cause: Throwable?) -> Unit): Cancellable {         val scope = CoroutineScope(SupervisorJob() + Dispatchers.Main)          scope.launch {             try {                 collect {                     onEach(it)                 }                  onCompletion(null)             } catch (e: Throwable) {                 onCompletion(e)             }         }          return object : Cancellable {             override fun cancel() {                 scope.cancel()             }         }     } }  fun &lt;T> Flow&lt;T>.wrapToAny(): AnyFlow&lt;T> = AnyFlow(this)<\/code><\/pre>\n<p>\u041f\u043e\u043b\u0443\u0447\u0438\u043c \u043f\u0440\u0438\u043c\u0435\u0440\u043d\u043e \u0442\u0430\u043a\u043e\u0439 \u043a\u043e\u0434: <\/p>\n<pre><code class=\"kotlin\">val newsFlow = MutableStateFlow&lt;NewsList?>(null) val flowNewsItem =  newsFlow.wrapToAny()   newsViewModel.flowNewsItem.collect { data in      \/\/...         } onCompletion: { error in     \/\/...           }<\/code><\/pre>\n<p>\u041f\u043e\u043f\u0440\u043e\u0431\u0443\u0435\u043c \u043e\u0431\u0435\u0440\u043d\u0443\u0442\u044c \u0432 Publisher \u0438 \u043f\u043e\u0434\u043a\u043b\u044e\u0447\u0438\u0442\u044c \u0432 Combine \u043a\u043e\u0434. \u0415\u0441\u0442\u044c \u043d\u0435\u0441\u043a\u043e\u043b\u044c\u043a\u043e \u0441\u043f\u043e\u0441\u043e\u0431\u043e\u0432 \u0441\u0434\u0435\u043b\u0430\u0442\u044c \u044d\u0442\u043e.<br \/>\u041c\u043e\u0436\u043d\u043e \u0434\u043e\u0431\u0430\u0432\u0438\u0442\u044c \u0441\u0442\u0430\u0442\u0438\u0447\u0435\u0441\u043a\u0438\u0439 \u043c\u0435\u0442\u043e\u0434 \u0434\u043b\u044f Publishers:<\/p>\n<pre><code class=\"swift\">extension Publishers {     static func createPublisher&lt;T>(         wrapper: AnyFlow&lt;T>     ) -> AnyPublisher&lt;T?, Error> {         var job: shared.Cancellable? = nil         \/\/Kotlinx_coroutines_coreJob? = nil         return Deferred {             Future { promise in                 job = wrapper.collect(onEach: { value in                     promise(.success(value))                 }, onCompletion: { error in                     promise(.failure(CustomError (error:error)))                 })             }.handleEvents( receiveCancel:                                 {                 job?.cancel()             })         }.eraseToAnyPublisher()     } }<\/code><\/pre>\n<p>\u0418\u043b\u0438 \u0441\u0434\u0435\u043b\u0430\u0442\u044c \u0441\u043f\u0435\u0446\u0438\u0430\u043b\u044c\u043d\u0443\u044e \u0441\u0442\u0440\u0443\u043a\u0442\u0443\u0440\u0443-\u043e\u0431\u0435\u0440\u0442\u043a\u0443 \u0434\u043b\u044f \u043d\u0430\u0448\u0435\u0439 \u043e\u0431\u0435\u0440\u0442\u043a\u0438 \u043f\u043e\u0442\u043e\u043a\u0430 (\u0441\u043f\u0430\u0441\u0438\u0431\u043e John O&#8217;Reilly \u0437\u0430 \u0438\u0434\u0435\u044e):<\/p>\n<pre><code class=\"swift\">public struct FlowPublisher&lt;T: AnyObject>: Publisher {     public typealias Output = T     public typealias Failure = Never          private let wrapper: AnyFlow&lt;Output>     public init(wrapper: AnyFlow&lt;Output>) {         self.wrapper = wrapper     }      public func receive&lt;S: Subscriber>(subscriber: S) where S.Input == Output, S.Failure == Failure {         let subscription = FlowSubscription(wrapper: wrapper,                                              subscriber: subscriber)         subscriber.receive(subscription: subscription)     }          final class FlowSubscription&lt;S: Subscriber>: Subscription where S.Input == Output, S.Failure == Failure {               private var subscriber: S?         private var job: shared.Cancellable? = nil          private let wrapper: AnyFlow&lt;Output>          init(wrapper: AnyFlow&lt;Output>, subscriber: S) {             self.wrapper = wrapper             self.subscriber = subscriber                        job = wrapper.collect(onEach: { data in                 subscriber.receive(data!)             }, onCompletion: { error in                 if let error = error {                     debugPrint(error.description())                 }                 subscriber.receive(completion: .finished)             })         }                func cancel() {             subscriber = nil             job?.cancel()         }          func request(_ demand: Subscribers.Demand) {}     } }<\/code><\/pre>\n<p>\u041a\u043e\u0434\u0430 \u043c\u043d\u043e\u0433\u043e, \u043d\u043e \u043f\u0438\u0441\u0430\u0442\u044c \u0435\u0433\u043e \u043e\u0434\u0438\u043d \u0440\u0430\u0437. \u0410 \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u0442\u044c \u043c\u044b \u043c\u043e\u0436\u0435\u043c \u0432\u043e\u0442 \u0442\u0430\u043a, \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u0443\u044f sink \u043e\u043f\u0435\u0440\u0430\u0442\u043e\u0440 \u0434\u043b\u044f \u0441\u0431\u043e\u0440\u0430 \u0440\u0435\u0437\u0443\u043b\u044c\u0442\u0430\u0442\u0430:<\/p>\n<pre><code class=\"swift\">  func loadData() {     let _ =  FlowPublisher&lt;NewsList>(wrapper: newsViewModel.flowNewsItem).sink { result in            \/\/...         } receiveValue: { data in            \/\/...                       }.store(in: &amp;store)     }<\/code><\/pre>\n<p>\u041f\u043e\u0434\u0433\u043e\u0442\u043e\u0432\u0438\u0442\u044c Flow \u043f\u0435\u0440\u0435\u043c\u0435\u043d\u043d\u044b\u0435 \u043d\u0430 \u0441\u0442\u043e\u0440\u043e\u043d\u0435 common \u043a\u043e\u0434\u0430 KMM \u043f\u0440\u043e\u0449\u0435 \u0438 \u0431\u044b\u0441\u0442\u0440\u0435\u0435, \u0447\u0435\u043c \u043f\u0438\u0441\u0430\u0442\u044c \u043f\u0440\u043e\u0441\u0442\u043e Publishers \u0434\u043b\u044f \u043a\u0430\u0436\u0434\u043e\u0433\u043e suspend \u043c\u0435\u0442\u043e\u0434\u0430.<\/p>\n<p>\u0411\u043e\u043b\u0435\u0435 \u043a\u0440\u0430\u0441\u0438\u0432\u044b\u043c \u0438 \u0430\u043a\u043a\u0443\u0440\u0430\u0442\u043d\u044b\u043c \u044f\u0432\u043b\u044f\u0435\u0442\u0441\u044f \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u043d\u0438\u0435 async\/await, \u043d\u0435 \u0437\u0440\u044f \u043c\u044b \u0436\u0434\u0430\u043b\u0438 \u0435\u0433\u043e \u0442\u0430\u043a \u0434\u043e\u043b\u0433\u043e.<br \/>\u041e\u0431\u0435\u0440\u0442\u043a\u0443 async\/await \u0432\u043e\u043a\u0440\u0443\u0433 suspended \u0444\u0443\u043d\u043a\u0446\u0438\u0438 \u0441\u0434\u0435\u043b\u0430\u0442\u044c \u0432\u0435\u0441\u044c\u043c\u0430 \u043f\u0440\u043e\u0441\u0442\u043e:<\/p>\n<pre><code class=\"swift\"> func loadNews() async-> Result&lt;[NewsItem],Error> {         return await withCheckedContinuation{ continuation in             newsService.getNewsList(completionHandler: { response,                                                          error in                 if let news = response?.content?.articles {                     continuation.resume(returning: .success(news))                 }                 if let error = response?.errorResponse {                     continuation.resume(returning:                               .failure(CustomError(error: error.message)))                 }                 if let error = error {                     continuation.resume(returning:                  .failure(CustomError(error: error.localizedDescription)))                 }             })         }     }<\/code><\/pre>\n<p>\u041a\u0430\u043a \u0438 \u0441\u0430\u043c \u0432\u044b\u0437\u043e\u0432:<\/p>\n<pre><code class=\"swift\">@MainActor     func loadAndSetup() {         Task {             let newsResult = await loadNews()             \/\/...             }         }     }<\/code><\/pre>\n<p>\u0414\u043b\u044f \u0440\u0430\u0431\u043e\u0442\u044b \u0441 \u043f\u043e\u0442\u043e\u043a\u0430\u043c\u0438 \u0434\u043e\u0431\u0430\u0432\u0438\u043c \u043e\u0431\u0449\u0443\u044e \u0444\u0443\u043d\u043a\u0446\u0438\u044e:<\/p>\n<pre><code class=\"swift\"> func requestAsync&lt;T>(wrapper: AnyFlow&lt;T>) async -> Result&lt;T?,Error> {         return await withCheckedContinuation{ continuation in             wrapper.collect { result in                 continuation.resume(returning: .success(result))             } onCompletion: { error in                 continuation.resume(returning:                                      .failure(CustomError(error: error)))             }         }     }  \/\/\u0412\u044b\u0437\u043e\u0432 @MainActor     func loadAndSetup() {         Task {             let result = await requestAsync(wrapper:                                              newsViewModel.flowNewsItem)            \/\/... \u041c\u0430\u0433\u0438\u044f \u043a\u0430\u043a\u0430\u044f-\u0442\u043e         }     }<\/code><\/pre>\n<p>\u0413\u043e\u0442\u043e\u0432\u043e. \u0412 \u0438\u0442\u043e\u0433\u0435 \u043c\u044b \u043f\u043e\u043b\u0443\u0447\u0438\u043b\u0438 \u0438\u043d\u0442\u0435\u0440\u0435\u0441\u043d\u044b\u0435 \u0440\u0435\u0448\u0435\u043d\u0438\u044f \u0434\u043b\u044f \u043a\u043e\u043c\u0431\u0438\u043d\u0430\u0446\u0438\u0438 Kotlin Multiplatform \u0438 Swift \u043a\u043e\u0434\u0430 \u043d\u0430 \u0441\u0442\u043e\u0440\u043e\u043d\u0435 iOS. \u041a\u0430\u043a\u043e\u0435 \u0438\u0437 \u043d\u0438\u0445 \u0432\u044b \u0432\u044b\u0431\u0435\u0440\u0435\u0442\u0435, \u043a\u0430\u043a \u043c\u043e\u0434\u0435\u0440\u043d\u0438\u0437\u0438\u0440\u0443\u0435\u0442\u0435 \u0438\/\u0438\u043b\u0438 \u043e\u043f\u0442\u0438\u043c\u0438\u0437\u0438\u0440\u0443\u0435\u0442\u0435, \u0443\u0436\u0435 \u0434\u0435\u043b\u043e \u0437\u0430 \u0432\u0430\u043c\u0438) <\/p>\n<p>\u0421\u043e\u0432\u0435\u0442\u0443\u044e \u043e\u0437\u043d\u0430\u043a\u043e\u043c\u0438\u0442\u044c\u0441\u044f \u0441\u043e \u0441\u043b\u0435\u0434\u0443\u044e\u0449\u0438\u043c\u0438 \u0438\u0441\u0442\u043e\u0447\u043d\u0438\u043a\u0430\u043c\u0438:<br \/><a href=\"https:\/\/johnoreilly.dev\/posts\/kotlinmultiplatform-swift-combine_publisher-flow\/\" rel=\"noopener noreferrer nofollow\">https:\/\/johnoreilly.dev\/posts\/kotlinmultiplatform-swift-combine_publisher-flow\/<\/a><br \/><a href=\"https:\/\/betterprogramming.pub\/using-kotlin-flow-in-swift-3e7b53f559b6\" rel=\"noopener noreferrer nofollow\">https:\/\/betterprogramming.pub\/using-kotlin-flow-in-swift-3e7b53f559b6<\/a><\/p>\n<p><a href=\"https:\/\/johnoreilly.dev\/posts\/swift_async_await_kotlin_coroutines\/\" rel=\"noopener noreferrer nofollow\">https:\/\/johnoreilly.dev\/posts\/swift_async_await_kotlin_coroutines\/<\/a><\/p>\n<p>\u0418 \u0438\u0441\u0445\u043e\u0434\u043d\u0438\u043a\u0430\u043c\u0438:<br \/><a href=\"https:\/\/github.com\/anioutkazharkova\/kn_network_sample.git\" rel=\"noopener noreferrer nofollow\">https:\/\/github.com\/anioutkazharkova\/kn_network_sample<\/a><\/p>\n<\/div>\n<\/div>\n<p> <!----> <!----><br \/> \u0441\u0441\u044b\u043b\u043a\u0430 \u043d\u0430 \u043e\u0440\u0438\u0433\u0438\u043d\u0430\u043b \u0441\u0442\u0430\u0442\u044c\u0438 <a href=\"https:\/\/habr.com\/ru\/post\/596497\/\"> https:\/\/habr.com\/ru\/post\/596497\/<\/a><\/p>\n","protected":false},"excerpt":{"rendered":"<div><\/div>\n<div id=\"post-content-body\" class=\"article-formatted-body article-formatted-body_version-2\">\n<div xmlns=\"http:\/\/www.w3.org\/1999\/xhtml\">\n<figure class=\"full-width\"><figcaption><\/figcaption><\/figure>\n<p><em>\u0412\u0441\u0435\u043c \u0434\u043e\u0431\u0440\u043e\u0433\u043e \u0432\u0440\u0435\u043c\u0435\u043d\u0438 \u0441\u0443\u0442\u043e\u043a! \u0421 \u0432\u0430\u043c\u0438 \u0410\u043d\u043d\u0430 \u0416\u0430\u0440\u043a\u043e\u0432\u0430, \u0432\u0435\u0434\u0443\u0449\u0438\u0439 \u0440\u0430\u0437\u0440\u0430\u0431\u043e\u0442\u0447\u0438\u043a \u043a\u043e\u043c\u043f\u0430\u043d\u0438\u0438 Usetech. \u041f\u0440\u043e\u0434\u043e\u043b\u0436\u0430\u0435\u043c \u0433\u043e\u0432\u043e\u0440\u0438\u0442\u044c \u043f\u0440\u043e Kotlin Multiplatform \u0438 \u0440\u0430\u0431\u043e\u0442\u0443 \u0441 \u0430\u0441\u0438\u043d\u0445\u0440\u043e\u043d\u043d\u044b\u043c\u0438 \u0444\u0443\u043d\u043a\u0446\u0438\u044f\u043c\u0438. \u0412 \u044d\u0442\u043e\u0439 \u0441\u0442\u0430\u0442\u044c\u0435 \u043c\u044b \u0431\u0443\u0434\u0435\u043c \u0440\u0430\u0441\u0441\u043c\u0430\u0442\u0440\u0438\u0432\u0430\u0442\u044c, \u043a\u0430\u043a \u043c\u043e\u0436\u043d\u043e \u0443\u0434\u043e\u0431\u043d\u043e \u043f\u043e\u0434\u043a\u043b\u044e\u0447\u0430\u0442\u044c Kotlin \u043e\u0431\u0449\u0438\u0439 \u043a\u043e\u0434 \u043d\u0430 \u0441\u0442\u043e\u0440\u043e\u043d\u0435 iOS, \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u0443\u044f \u0432\u043e\u0437\u043c\u043e\u0436\u043d\u043e\u0441\u0442\u0438 Swift. \u0410 \u0438\u043c\u0435\u043d\u043d\u043e, \u043a\u0430\u043a \u0440\u0430\u0431\u043e\u0442\u0430\u0442\u044c \u0441 Combine Publishers \u0438 \u043d\u043e\u0432\u044b\u043c async\/await.<\/em> <\/p>\n<p>\u041a\u043e\u043d\u0446\u0435\u043f\u0446\u0438\u044f Kotlin Multiplatform \u043f\u043e\u0437\u0432\u043e\u043b\u044f\u0435\u0442 \u043d\u0430\u043c \u0441\u0434\u0435\u043b\u0430\u0442\u044c \u043a\u043e\u0434 \u043c\u0430\u043a\u0441\u0438\u043c\u0430\u043b\u044c\u043d\u043e \u043e\u0431\u0449\u0438\u043c, \u0442.\u0435 \u0432\u044b\u043d\u0435\u0441\u0442\u0438 \u043f\u0440\u0430\u043a\u0442\u0438\u0447\u0435\u0441\u043a\u0438 \u0432\u0441\u0435 \u0432 \u043e\u0431\u0449\u0443\u044e \u0447\u0430\u0441\u0442\u044c. <\/p>\n<p>\u0415\u0441\u043b\u0438 \u043d\u0430 \u0441\u0442\u043e\u0440\u043e\u043d\u0435 common, \u043c\u044b \u043e\u043f\u0435\u0440\u0438\u0440\u0443\u0435\u043c \u043a\u043e\u0440\u0443\u0442\u0438\u043d\u0430\u043c\u0438 \u0438 suspend \u0444\u0443\u043d\u043a\u0446\u0438\u044f\u043c\u0438:<\/p>\n<pre><code class=\"kotlin\">suspend fun getNewsList():ContentResponse&lt;NewsList>{ return networkClient.request(Request(url = NEWS_LIST))  }<\/code><\/pre>\n<p>\u0422\u043e \u043d\u0430 \u0441\u0442\u043e\u0440\u043e\u043d\u0435 iOS \u043f\u0440\u043e\u0435\u043a\u0442\u0430 \u043d\u0430\u0442\u0438\u0432\u043d\u043e\u0433\u043e \u0431\u043b\u0430\u0433\u043e\u0434\u0430\u0440\u044f \u043f\u043e\u0434\u0434\u0435\u0440\u0436\u043a\u0435 interop Kotlin\/Obj-C \u0441 \u0432\u0435\u0440\u0441\u0438\u0438 Kotlin 1.4 suspend \u0444\u0443\u043d\u043a\u0446\u0438\u0438 \u043f\u0440\u0435\u043e\u0431\u0440\u0430\u0437\u0443\u044e\u0442\u0441\u044f \u0432 \u0444\u0443\u043d\u043a\u0446\u0438\u0438 \u0441 completion handler:<\/p>\n<pre><code class=\"swift\">- (void)getNewsListWithCompletionHandler:(void (^)(SharedContentResponse&lt;SharedNewsList *> * _Nullable, NSError * _Nullable))completionHandler __attribute__((swift_name(\"getNewsList(completionHandler:)\")));  \/\/Swift newsService.getNewsList(completionHandler: { response, error in    if let data = response.content?.articles {     \/\/...     }                                                                                         }<\/code><\/pre>\n<p>\u0414\u0430\u043b\u0435\u0435 \u043c\u044b \u043c\u043e\u0436\u0435\u043c \u0432 \u044d\u0442\u043e\u043c \u0431\u043b\u043e\u043a\u0435 \u043b\u0438\u0431\u043e \u0432\u044b\u0437\u0432\u0430\u0442\u044c \u0432\u044b\u0432\u043e\u0434 \u0434\u0430\u043d\u043d\u044b\u0445, \u043b\u0438\u0431\u043e \u0432\u044b\u043f\u043e\u043b\u043d\u0435\u043d\u0438\u0435 \u043a\u0430\u043a\u043e\u0433\u043e-\u0442\u043e \u0441\u043b\u0435\u0434\u0443\u044e\u0449\u0435\u0433\u043e \u043c\u0435\u0442\u043e\u0434\u0430. \u0412\u0441\u0435 \u0441\u0442\u0430\u043d\u0434\u0430\u0440\u0442\u043d\u043e \u0438 \u043f\u0440\u043e\u0441\u0442\u043e. <br \/>\u041e\u0434\u043d\u0430\u043a\u043e, \u043d\u0435 \u0432\u0441\u0435 \u043b\u044e\u0431\u044f\u0442 \u043f\u0440\u043e\u0441\u0442\u043e\u0439 \u0441\u0438\u043d\u0442\u0430\u043a\u0441\u0438\u0441 completion handler. \u0410 \u0435\u0449\u0435 \u043c\u044b \u043f\u0440\u0435\u043a\u0440\u0430\u0441\u043d\u043e \u0437\u043d\u0430\u0435\u043c, \u0447\u0442\u043e \u0435\u0441\u043b\u0438 \u0438\u043c\u0438 \u0437\u043b\u043e\u0443\u043f\u043e\u0442\u0440\u0435\u0431\u043b\u044f\u0442\u044c, \u043c\u043e\u0436\u043d\u043e \u043b\u0435\u0433\u043a\u043e \u043f\u043e\u043f\u0430\u0441\u0442\u044c \u0432 \u0441\u0438\u0442\u0443\u0430\u0446\u0438\u044e callback hell \u0438 \u043f\u043e\u0442\u0435\u0440\u044f\u0442\u044c \u0447\u0438\u0442\u0430\u0431\u0435\u043b\u044c\u043d\u043e\u0441\u0442\u044c \u0438 \u0447\u0438\u0441\u0442\u043e\u0442\u0443 \u043a\u043e\u0434\u0430. <\/p>\n<p>\u0422\u0430\u043a\u0436\u0435 \u043d\u0435 \u0441\u0442\u043e\u0438\u0442 \u0437\u0430\u0431\u044b\u0432\u0430\u0442\u044c, \u0447\u0442\u043e \u0432 \u0437\u0430\u0432\u0438\u0441\u0438\u043c\u043e\u0441\u0442\u0438 \u043e\u0442 \u043f\u043e\u0441\u0442\u0430\u0432\u043b\u0435\u043d\u043d\u043e\u0439 \u0437\u0430\u0434\u0430\u0447\u0438 \u0443 \u043d\u0430\u0441 \u043c\u043e\u0433\u0443\u0442 \u0431\u044b\u0442\u044c \u043d\u0435 \u0442\u043e\u043b\u044c\u043a\u043e \u043e\u0431\u043e\u0431\u0449\u0430\u0435\u043c\u044b\u0435 \u043c\u0435\u0442\u043e\u0434\u044b.  \u041a\u043e\u0434 \u043f\u043b\u0430\u0442\u0444\u043e\u0440\u043c\u0435\u043d\u043d\u044b\u0445 \u043f\u0440\u043e\u0435\u043a\u0442\u043e\u0432 \u0443 \u043d\u0430\u0441 \u043c\u043e\u0436\u0435\u0442 \u0431\u044b\u0442\u044c \u043d\u0435 \u0438\u0434\u0435\u043d\u0442\u0438\u0447\u0435\u043d, \u043f\u043e\u044d\u0442\u043e\u043c\u0443 \u043d\u0435\u043b\u044c\u0437\u044f \u0438\u0441\u043a\u043b\u044e\u0447\u0430\u0442\u044c \u043b\u043e\u0433\u0438\u043a\u0438 \u0441\u0443\u0433\u0443\u0431\u043e \u043d\u0430\u0442\u0438\u0432\u043d\u043e\u0439, \u0432\u044b\u0437\u043e\u0432\u044b \u043a\u043e\u0442\u043e\u0440\u043e\u0439 \u043c\u044b \u043c\u043e\u0436\u0435\u043c \u0441\u043e\u0447\u0435\u0442\u0430\u0442\u044c \u0441 \u0432\u044b\u0437\u043e\u0432\u0430\u043c\u0438 \u043b\u043e\u0433\u0438\u043a\u0438 \u0438\u0437 \u043e\u0431\u0449\u0435\u0433\u043e \u043c\u043e\u0434\u0443\u043b\u044f. \u0427\u0442\u043e \u0432\u043f\u043e\u043b\u043d\u0435 \u043b\u043e\u0433\u0438\u0447\u043d\u043e. \u041f\u043e\u044d\u0442\u043e\u043c\u0443 \u0432\u043f\u043e\u043b\u043d\u0435 \u043d\u043e\u0440\u043c\u0430\u043b\u044c\u043d\u043e, \u0447\u0442\u043e \u043c\u044b \u0440\u0435\u0448\u0438\u043c \u043f\u0440\u0438\u043c\u0435\u043d\u0438\u0442\u044c \u0437\u0434\u0435\u0441\u044c \u0434\u043e\u0441\u0442\u0443\u043f\u043d\u044b\u0435 \u043f\u043e\u0434\u0445\u043e\u0434\u044b \u043a\u043e\u043d\u043a\u0440\u0435\u0442\u043d\u043e\u0439 \u043f\u043b\u0430\u0442\u0444\u043e\u0440\u043c\u044b. <\/p>\n<p>\u041f\u043e\u043f\u0440\u043e\u0431\u0443\u0435\u043c \u0441\u0434\u0435\u043b\u0430\u0442\u044c \u043d\u0430\u0448 Kotlin \u043a\u043e\u0434 \u0441\u043e\u0432\u043c\u0435\u0441\u0442\u0438\u043c\u044b\u043c \u0441 Combine Publishers. \u0414\u043b\u044f \u044d\u0442\u043e\u0433\u043e \u043f\u0440\u0435\u0432\u0440\u0430\u0442\u0438\u043c \u0432\u044b\u0437\u043e\u0432 \u043d\u0430\u0448\u0435\u0439 suspend \u0444\u0443\u043d\u043a\u0446\u0438\u0438 \u0432 AnyPublisher \u0441 \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u043d\u0438\u0435\u043c Future Deferred \u0438 Promise. <\/p>\n<pre><code class=\"swift\"> func getNewsList()-> AnyPublisher&lt;[NewsItem], Error> {         return Deferred {             Future { promise in                 self.getNewsList { response, error in                     if let data = response?.content?.articles {                         promise(.success(data))                     }                     if let error = response?.errorResponse {                         promise(.failure(CustomError(error: error.message)))                     }                     if let error = error {                         promise(.failure(error))                     }                 }             }                      }.eraseToAnyPublisher()<\/code><\/pre>\n<p>\u0414\u043b\u044f \u0443\u0434\u043e\u0431\u0441\u0442\u0432\u0430 \u043c\u043e\u0436\u043d\u043e \u0434\u0430\u0436\u0435 \u0432\u044b\u043d\u0435\u0441\u0442\u0438 \u0432\u044b\u0437\u043e\u0432 \u043c\u0435\u0442\u043e\u0434\u0430 \u0432 extension \u0441\u0435\u0440\u0432\u0438\u0441\u0430, \u043e\u0441\u0443\u0449\u0435\u0441\u0442\u0432\u043b\u044f\u044e\u0449\u0435\u0433\u043e \u0437\u0430\u043f\u0440\u043e\u0441:<\/p>\n<pre><code class=\"swift\">extension NewsService {          func getNewsList()-> AnyPublisher&lt;[NewsItem], Error> {         return Deferred {             Future { promise in              \/\/...                    }         }     }<\/code><\/pre>\n<p>\u0412\u044b\u0437\u043e\u0432 \u0432 \u043a\u043e\u0434\u0435 \u043d\u0430\u0448\u0435\u0433\u043e ObservableObject (\u0435\u0441\u043b\u0438 \u043c\u044b \u0433\u043e\u0432\u043e\u0440\u0438\u043c \u043f\u0440\u043e SwiftUI) \u0438\u043b\u0438 \u0434\u0440\u0443\u0433\u043e\u0439 \u0447\u0430\u0441\u0442\u0438 \u043b\u043e\u0433\u0438\u043a\u0438 \u0431\u0443\u0434\u0435\u0442 \u0430\u0431\u0441\u043e\u043b\u044e\u0442\u043d\u043e \u0442\u0430\u043a\u0438\u043c \u0436\u0435, \u043a\u0430\u043a \u0438 \u0432 \u0434\u0440\u0443\u0433\u0438\u0445 \u0441\u043b\u0443\u0447\u0430\u044f\u0445 \u0440\u0430\u0431\u043e\u0442\u044b \u0441 Publishers:<\/p>\n<pre><code class=\"swift\">func loadData() {      let _ =  newsService.getNewsList().sink { result in             switch result {             case .failure(let error):                 print(error.localizedDescription)             default:                 break             }         } receiveValue: { data in             self.items = [NewsItem]()             self.items.append(contentsOf: data)         }.store(in: &amp;store)      }<\/code><\/pre>\n<p>\u0427\u0442\u043e \u0436, \u043f\u043e\u043a\u0430 \u044d\u0442\u043e \u0432\u044b\u0433\u043b\u044f\u0434\u0438\u0442, \u043a\u0430\u043a \u043f\u0435\u0440\u0435\u043d\u043e\u0441 \u0440\u0435\u0448\u0435\u043d\u0438\u044f \u0434\u043b\u044f \u0440\u0430\u0431\u043e\u0442\u044b \u0441 Combine. \u041e\u0441\u043e\u0431\u043e\u0433\u043e \u043f\u0440\u043e\u0444\u0438\u0442\u0430 \u043d\u0435 \u0447\u0443\u0432\u0441\u0442\u0432\u0443\u0435\u0442\u0441\u044f. \u0422\u0435\u043c \u0431\u043e\u043b\u0435\u0435, \u0435\u0441\u043b\u0438 \u043f\u0440\u0435\u0434\u0441\u0442\u0430\u0432\u0438\u0442\u044c, \u0447\u0442\u043e \u043d\u0430\u043c \u043f\u0440\u0438\u0434\u0435\u0442\u0441\u044f \u043e\u0431\u0435\u0440\u043d\u0443\u0442\u044c \u0432 Publisher \u043a\u0430\u0436\u0434\u044b\u0439 \u043c\u0435\u0442\u043e\u0434, \u043a\u043e\u0442\u043e\u0440\u044b\u0439 \u043c\u044b \u0431\u0443\u0434\u0435\u043c \u0432\u044b\u0437\u044b\u0432\u0430\u0442\u044c \u043d\u0430 \u0441\u0442\u043e\u0440\u043e\u043d\u0435 iOS. <br \/>\u041d\u0430\u0434\u043e \u043a\u0430\u043a-\u0442\u043e \u043e\u0431\u043e\u0431\u0449\u0438\u0442\u044c.<br \/>\u041c\u043e\u0436\u043d\u043e \u043f\u043e\u043f\u0440\u043e\u0431\u043e\u0432\u0430\u0442\u044c \u0441\u0434\u0435\u043b\u0430\u0442\u044c \u0441\u0432\u043e\u0435\u043e\u0431\u0440\u0430\u0437\u043d\u044b\u0439 \u043c\u0435\u043d\u0435\u0434\u0436\u0435\u0440 \u0437\u0430\u0434\u0430\u0447 \u043d\u0430 \u0441\u0442\u043e\u0440\u043e\u043d\u0435 \u043e\u0431\u0449\u0435\u0433\u043e KMM \u043a\u043e\u0434\u0430, \u043d\u043e \u0432 \u0431\u043e\u043b\u044c\u0448\u0438\u043d\u0441\u0442\u0432\u0435 \u0441\u043b\u0443\u0447\u0430\u0435\u0432 \u044d\u0442\u043e \u0431\u0430\u043d\u0430\u043b\u044c\u043d\u044b\u0439 \u043e\u0432\u0435\u0440\u0438\u043d\u0436\u0435\u043d\u0435\u0440\u0438\u043d\u0433. \u041f\u043e\u043f\u0440\u043e\u0431\u0443\u0435\u043c \u043f\u043e\u0439\u0442\u0438 \u0447\u0435\u0440\u0435\u0437 Kotlin Flows, \u043a\u043e\u0442\u043e\u0440\u044b\u0435 \u043c\u044b \u043c\u043e\u0436\u0435\u043c \u043f\u0440\u0435\u0434\u0441\u0442\u0430\u0432\u0438\u0442\u044c \u0432 \u043e\u0431\u0449\u0435\u043c \u0432\u0438\u0434\u0435 \u043a\u0430\u043a Flow&lt;T>.<\/p>\n<p>\u041d\u0430 \u0441\u0442\u043e\u0440\u043e\u043d\u0435 Kotlin Multiplatform \u0440\u0430\u0431\u043e\u0442\u0430 \u0441 Flow \u0432\u044b\u0433\u043b\u044f\u0434\u0438\u0442 \u0442\u0430\u043a:<\/p>\n<pre><code class=\"kotlin\">\/\/ViewModel  val newsFlow = MutableStateFlow&lt;NewsList?>(null)  fun loadData() {         scope.launch {            val result =  newsService.getNewsList()             newsFlow.value = result.content         }     }<\/code><\/pre>\n<p>\u0414\u043b\u044f \u0430\u043d\u0434\u0440\u043e\u0438\u0434 \u043f\u043e\u043b\u0443\u0447\u0435\u043d\u0438\u0435 \u0434\u0430\u043d\u043d\u044b\u0445 c Flow \u0438\u0434\u0435\u0442 \u043d\u0430\u0442\u0438\u0432\u043d\u043e \u0438 \u043f\u0440\u043e\u0441\u0442\u043e, \u043d\u0430\u043c \u0434\u043e\u0441\u0442\u0430\u0442\u043e\u0447\u043d\u043e \u043f\u043e\u0434\u043f\u0438\u0441\u0430\u0442\u044c\u0441\u044f \u043d\u0430 \u0441\u043e\u0431\u044b\u0442\u0438\u0435:<\/p>\n<pre><code class=\"kotlin\"> lifecycleScope.launch {             repeatOnLifecycle(Lifecycle.State.STARTED) {                 viewModel.newsList.collect {                     setupNews(it)                 }             }          }<\/code><\/pre>\n<p>\u0423\u0441\u043b\u043e\u0432\u043d\u043e \u043f\u0440\u043e\u0441\u0442\u043e. \u0414\u043b\u044f iOS \u044d\u0442\u043e suspend \u0444\u0443\u043d\u043a\u0446\u0438\u044f, \u043a\u043e\u0442\u043e\u0440\u0430\u044f \u0442\u0440\u0435\u0431\u0443\u0435\u0442 \u0441\u0432\u043e\u0438 \u043f\u0430\u0440\u0430\u043c\u0435\u0442\u0440\u044b, \u043e\u0434\u043d\u0438\u043c \u0438\u0437 \u043a\u043e\u0442\u043e\u0440\u044b\u0445 \u044f\u0432\u043b\u044f\u0435\u0442\u0441\u044f \u0441\u043f\u0435\u0446\u0438\u0430\u043b\u044c\u043d\u044b\u0439 \u043a\u043e\u043b\u043b\u0435\u043a\u0442\u043e\u0440 Kotlinx_coroutines_coreFlowCollector:<\/p>\n<pre><code class=\"swift\">typealias Collector = Kotlinx_coroutines_coreFlowCollector  class Observer: Collector {     let callback:(Any?) -> Void          init(callback: @escaping (Any?) -> Void) {         self.callback = callback     }          func emit(value: Any?, completionHandler: @escaping (KotlinUnit?, Error?) -> Void) {         callback(value)         completionHandler(KotlinUnit(), nil)     } }<\/code><\/pre>\n<p>\u041f\u043e\u044d\u0442\u043e\u043c\u0443 \u043f\u043e\u0434\u043f\u0438\u0441\u043a\u0430 \u0443 \u043d\u0430\u0441 \u0431\u0443\u0434\u0435\u0442 \u0432\u044b\u0433\u043b\u044f\u0434\u0435\u0442\u044c \u043d\u0435\u043c\u043d\u043e\u0433\u043e \u043f\u043e-\u0434\u0440\u0443\u0433\u043e\u043c\u0443:<\/p>\n<pre><code class=\"kotlin\">lazy var collector: Observer = {         let collector = Observer {value in             if let value = value as? NewsList {                 let data = value.articles                 self.processNews(data: data)             }         }         return collector     }()    lazy var newsViewModel: NewsViewModel = {         let newsViewModel =  NewsViewModel()         newsViewModel.newsFlow.collect(collector: self.collector,                                         completionHandler: {_,_ in })         return newsViewModel     }()     <\/code><\/pre>\n<p>\u0422\u0430\u043a\u0436\u0435 \u043c\u043e\u0436\u043d\u043e \u0443\u043f\u0440\u043e\u0441\u0442\u0438\u0442\u044c \u0438 \u043e\u0431\u043e\u0431\u0449\u0438\u0442\u044c \u0432\u044b\u0437\u043e\u0432 \u0441 \u043f\u043e\u043c\u043e\u0449\u044c\u044e \u043e\u0431\u0435\u0440\u0442\u043a\u0438, \u043a\u043e\u0442\u043e\u0440\u0430\u044f \u0432\u043d\u0443\u0442\u0440\u0438 \u0431\u0443\u0434\u0435\u0442 \u0440\u0430\u0431\u043e\u0442\u0430\u0442\u044c \u0441\u043e \u0441\u0432\u043e\u0438\u043c Coroutine scope:<\/p>\n<pre><code class=\"swift\">class AnyFlow&lt;T>(source: Flow&lt;T>): Flow&lt;T> by source {     fun collect(onEach: (T) -> Unit,                  onCompletion: (cause: Throwable?) -> Unit): Cancellable {         val scope = CoroutineScope(SupervisorJob() + Dispatchers.Main)          scope.launch {             try {                 collect {                     onEach(it)                 }                  onCompletion(null)             } catch (e: Throwable) {                 onCompletion(e)             }         }          return object : Cancellable {             override fun cancel() {                 scope.cancel()             }         }     } }  fun &lt;T> Flow&lt;T>.wrapToAny(): AnyFlow&lt;T> = AnyFlow(this)<\/code><\/pre>\n<p>\u041f\u043e\u043b\u0443\u0447\u0438\u043c \u043f\u0440\u0438\u043c\u0435\u0440\u043d\u043e \u0442\u0430\u043a\u043e\u0439 \u043a\u043e\u0434: <\/p>\n<pre><code class=\"kotlin\">val newsFlow = MutableStateFlow&lt;NewsList?>(null) val flowNewsItem =  newsFlow.wrapToAny()   newsViewModel.flowNewsItem.collect { data in      \/\/...         } onCompletion: { error in     \/\/...           }<\/code><\/pre>\n<p>\u041f\u043e\u043f\u0440\u043e\u0431\u0443\u0435\u043c \u043e\u0431\u0435\u0440\u043d\u0443\u0442\u044c \u0432 Publisher \u0438 \u043f\u043e\u0434\u043a\u043b\u044e\u0447\u0438\u0442\u044c \u0432 Combine \u043a\u043e\u0434. \u0415\u0441\u0442\u044c \u043d\u0435\u0441\u043a\u043e\u043b\u044c\u043a\u043e \u0441\u043f\u043e\u0441\u043e\u0431\u043e\u0432 \u0441\u0434\u0435\u043b\u0430\u0442\u044c \u044d\u0442\u043e.<br \/>\u041c\u043e\u0436\u043d\u043e \u0434\u043e\u0431\u0430\u0432\u0438\u0442\u044c \u0441\u0442\u0430\u0442\u0438\u0447\u0435\u0441\u043a\u0438\u0439 \u043c\u0435\u0442\u043e\u0434 \u0434\u043b\u044f Publishers:<\/p>\n<pre><code class=\"swift\">extension Publishers {     static func createPublisher&lt;T>(         wrapper: AnyFlow&lt;T>     ) -> AnyPublisher&lt;T?, Error> {         var job: shared.Cancellable? = nil         \/\/Kotlinx_coroutines_coreJob? = nil         return Deferred {             Future { promise in                 job = wrapper.collect(onEach: { value in                     promise(.success(value))                 }, onCompletion: { error in                     promise(.failure(CustomError (error:error)))                 })             }.handleEvents( receiveCancel:                                 {                 job?.cancel()             })         }.eraseToAnyPublisher()     } }<\/code><\/pre>\n<p>\u0418\u043b\u0438 \u0441\u0434\u0435\u043b\u0430\u0442\u044c \u0441\u043f\u0435\u0446\u0438\u0430\u043b\u044c\u043d\u0443\u044e \u0441\u0442\u0440\u0443\u043a\u0442\u0443\u0440\u0443-\u043e\u0431\u0435\u0440\u0442\u043a\u0443 \u0434\u043b\u044f \u043d\u0430\u0448\u0435\u0439 \u043e\u0431\u0435\u0440\u0442\u043a\u0438 \u043f\u043e\u0442\u043e\u043a\u0430 (\u0441\u043f\u0430\u0441\u0438\u0431\u043e John O&#8217;Reilly \u0437\u0430 \u0438\u0434\u0435\u044e):<\/p>\n<pre><code class=\"swift\">public struct FlowPublisher&lt;T: AnyObject>: Publisher {     public typealias Output = T     public typealias Failure = Never          private let wrapper: AnyFlow&lt;Output>     public init(wrapper: AnyFlow&lt;Output>) {         self.wrapper = wrapper     }      public func receive&lt;S: Subscriber>(subscriber: S) where S.Input == Output, S.Failure == Failure {         let subscription = FlowSubscription(wrapper: wrapper,                                              subscriber: subscriber)         subscriber.receive(subscription: subscription)     }          final class FlowSubscription&lt;S: Subscriber>: Subscription where S.Input == Output, S.Failure == Failure {               private var subscriber: S?         private var job: shared.Cancellable? = nil          private let wrapper: AnyFlow&lt;Output>          init(wrapper: AnyFlow&lt;Output>, subscriber: S) {             self.wrapper = wrapper             self.subscriber = subscriber                        job = wrapper.collect(onEach: { data in                 subscriber.receive(data!)             }, onCompletion: { error in                 if let error = error {                     debugPrint(error.description())                 }                 subscriber.receive(completion: .finished)             })         }                func cancel() {             subscriber = nil             job?.cancel()         }          func request(_ demand: Subscribers.Demand) {}     } }<\/code><\/pre>\n<p>\u041a\u043e\u0434\u0430 \u043c\u043d\u043e\u0433\u043e, \u043d\u043e \u043f\u0438\u0441\u0430\u0442\u044c \u0435\u0433\u043e \u043e\u0434\u0438\u043d \u0440\u0430\u0437. \u0410 \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u0442\u044c \u043c\u044b \u043c\u043e\u0436\u0435\u043c \u0432\u043e\u0442 \u0442\u0430\u043a, \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u0443\u044f sink \u043e\u043f\u0435\u0440\u0430\u0442\u043e\u0440 \u0434\u043b\u044f \u0441\u0431\u043e\u0440\u0430 \u0440\u0435\u0437\u0443\u043b\u044c\u0442\u0430\u0442\u0430:<\/p>\n<pre><code class=\"swift\">  func loadData() {     let _ =  FlowPublisher&lt;NewsList>(wrapper: newsViewModel.flowNewsItem).sink { result in            \/\/...         } receiveValue: { data in            \/\/...                       }.store(in: &amp;store)     }<\/code><\/pre>\n<p>\u041f\u043e\u0434\u0433\u043e\u0442\u043e\u0432\u0438\u0442\u044c Flow \u043f\u0435\u0440\u0435\u043c\u0435\u043d\u043d\u044b\u0435 \u043d\u0430 \u0441\u0442\u043e\u0440\u043e\u043d\u0435 common \u043a\u043e\u0434\u0430 KMM \u043f\u0440\u043e\u0449\u0435 \u0438 \u0431\u044b\u0441\u0442\u0440\u0435\u0435, \u0447\u0435\u043c \u043f\u0438\u0441\u0430\u0442\u044c \u043f\u0440\u043e\u0441\u0442\u043e Publishers \u0434\u043b\u044f \u043a\u0430\u0436\u0434\u043e\u0433\u043e suspend \u043c\u0435\u0442\u043e\u0434\u0430.<\/p>\n<p>\u0411\u043e\u043b\u0435\u0435 \u043a\u0440\u0430\u0441\u0438\u0432\u044b\u043c \u0438 \u0430\u043a\u043a\u0443\u0440\u0430\u0442\u043d\u044b\u043c \u044f\u0432\u043b\u044f\u0435\u0442\u0441\u044f \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u043d\u0438\u0435 async\/await, \u043d\u0435 \u0437\u0440\u044f \u043c\u044b \u0436\u0434\u0430\u043b\u0438 \u0435\u0433\u043e \u0442\u0430\u043a \u0434\u043e\u043b\u0433\u043e.<br \/>\u041e\u0431\u0435\u0440\u0442\u043a\u0443 async\/await \u0432\u043e\u043a\u0440\u0443\u0433 suspended \u0444\u0443\u043d\u043a\u0446\u0438\u0438 \u0441\u0434\u0435\u043b\u0430\u0442\u044c \u0432\u0435\u0441\u044c\u043c\u0430 \u043f\u0440\u043e\u0441\u0442\u043e:<\/p>\n<pre><code class=\"swift\"> func loadNews() async-> Result&lt;[NewsItem],Error> {         return await withCheckedContinuation{ continuation in             newsService.getNewsList(completionHandler: { response,        <\/code><\/pre>\n<\/div>\n<\/div>\n","protected":false},"author":1,"featured_media":0,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[],"tags":[],"class_list":["post-327009","post","type-post","status-publish","format-standard","hentry"],"_links":{"self":[{"href":"https:\/\/savepearlharbor.com\/index.php?rest_route=\/wp\/v2\/posts\/327009","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/savepearlharbor.com\/index.php?rest_route=\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/savepearlharbor.com\/index.php?rest_route=\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/savepearlharbor.com\/index.php?rest_route=\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/savepearlharbor.com\/index.php?rest_route=%2Fwp%2Fv2%2Fcomments&post=327009"}],"version-history":[{"count":0,"href":"https:\/\/savepearlharbor.com\/index.php?rest_route=\/wp\/v2\/posts\/327009\/revisions"}],"wp:attachment":[{"href":"https:\/\/savepearlharbor.com\/index.php?rest_route=%2Fwp%2Fv2%2Fmedia&parent=327009"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/savepearlharbor.com\/index.php?rest_route=%2Fwp%2Fv2%2Fcategories&post=327009"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/savepearlharbor.com\/index.php?rest_route=%2Fwp%2Fv2%2Ftags&post=327009"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}