CXFoundation(中文)

Combine + Foundation，基于CombineX构建。

通知

此库仍在测试中，因此请不要在生产环境中使用！

🐱

let ping = Timer.cx.publish(every: 1, on: RunLoop.main, in: .default)
    .sink { d in 
        // ping
    }

let request = URLSession.shared.cx.dataTaskPublisher(for: host)
    .sink { (data, response) in
        // update ui
    }

let observe = NotificationCenter.default.cx.publisher(for: name)
    .sink { notification in
        // 
    }

let cancel = upstream
    .receive(on: RunLoop.main.cx.scheduler)
    .sink { v in
        //
    }

dependencies.append(
    .package(url: "https://github.com/cx-org/CXFoundation", .branch("master"))
)

pod 'CxFoundation', :git => 'https://github.com/cx-org/CXFoundation.git', :branch => 'master'

github "cx-org/CXFoundation" "master"

Combine直接扩展系统类型。我们无法在相同位置定义相同的接口 - 它无法编译。例如

extension URLSession {
    struct DataTaskPublisher: Publisher {
        // ...
    }
}

CXCompatible提供所有cx接口的实现，但基于Combine，无需CombineX依赖。这可以帮助您轻松迁移。