woodycatliu

The Composable Architecture (可组装架构)

The Composable Architecture (简写为TCA) 让你用统一、便于理解的方式来搭建应用程序，它兼顾了组装，测试，以及功效。你可以在 SwiftUI，UIKit，以及其他框架，和任何苹果的平台（iOS、macOS、tvOS、和 watchOS）上使用 TCA。

• 什么是TCA?
• 更多
• 示例
• 基本用法
• 补充性的库
• 常见问题

woodycatliu

import Combine

extension CurrentValueSubject where Failure == Never {
    convenience init(with publisher: AnyPublisher<Output, Failure>, value: Output) {
        self.init(value)
        publisher.receive(subscriber: AnySubscriber(self))
    }
}

woodycatliu

//
//  BindingValueSubject.swift
//
//
//  Created by Woody Liu on 2023/7/2.
//

import Combine

@frozen public struct BindingValue<Output>: Publisher {

woodycatliu

import Combine

extension Publisher where Failure == Never {
    
    public func bind(to binder: CombineBinder<Output>) -> AnyCancellable {
        subscribe(binder)
        return AnyCancellable(binder)
    }
    

woodycatliu

/// Property Wrapper that wraps an `AnyPublisher`, which is backed by a `CurrentValueSubject`. This is to make it possible  to easily expose just a publisher to consumers of a type,
/// without also exposing the `CurrentValueSubject` to consumers, effectively allowing for public reads and private writes of a publisher.
@propertyWrapper
struct CurrentValueBacked<Output> {

  private var subject: CurrentValueSubject<Output, Never>
    init(_ output: Output) {
        subject = CurrentValueSubject<Output, Never>(output)
  }

woodycatliu

extension Publisher {
    
    public func filterTo(_ isIncluded: @escaping (Self.Output) -> Bool) -> AnyPublisher<Output, Failure> {
        self.filter(isIncluded).eraseToAnyPublisher()
    }
    
    public func filterTo(equalTo value: Output) -> AnyPublisher<Output, Failure> where Output: AnyObject&Equatable {
        return self.filterTo { [weak value] output in
            value == output
        }

woodycatliu

Swift 5.3 Combine

With RxSwift, it can support bind to a function/closure to more readability.

Example

textField.rx.text.orEmpty.asObservable()
            .subscribeOn(MainScheduler.instance)
            .bind(onNext: receiveText(_:))
 .disposed(by: disBag)

woodycatliu

Dump Streams with Swift Combine

When I develop the project in Swift, The Swift.print is the most commonly used.
But some times I wish more readable dectect value like use dump, even if I programming in Combine. So I create the combine extension for dump.

You can use like below.

 publisher

woodycatliu

import UIKit
import RxSwift
import RxCocoa

struct WRxAnimation {
    let view: UIView
    let transform: CGAffineTransform
}

woodycatliu

import Combine

extension Publisher {
    
    public func sink(completion completionHandle: (() -> Void)? = nil, receiveError: ((Self.Failure) -> Void)? = nil, receiveValue: ((Self.Output) -> Void)? = nil) -> AnyCancellable {
        return self.sink(receiveCompletion: { completion in
            switch completion {
            case .failure(let error):
                receiveError?(error)
            case .finished: