serhiybutz

final class Registry {
    private var borrowings: [Borrowing] = []
    func copyWithAdded(_ borrowing: Borrowing) -> Registry {
        let new = Registry()
        new.borrowings = borrowings + [borrowing]
        return new
    }
    func copyWithRemoved(_ borrowing: Borrowing) -> Registry {
        let new = Registry()
        new.borrowings = borrowings.filter { $0 !== borrowing }

serhiybutz

public protocol Borrowable {
    var oid: ObjectIdentifier { get }
}
extension Shared: Borrowable {
    public var oid: ObjectIdentifier { ObjectIdentifier(self) }
}

serhiybutz

p1: receive subscription: ([1, 2])
p2: receive subscription: (["foo"])
zip: receive subscription: (Zip)
zip: request unlimited
p1: request unlimited
p1: receive value: (1)
p1: receive value: (2)
p1: receive finished
p2: request unlimited
p2: receive value: (foo)

serhiybutz

import Combine

extension Publishers {
    public struct WithLatestFrom<Upstream: Publisher, Other: Publisher>:
        Publisher where Upstream.Failure == Other.Failure
    {
        // MARK: - Types

        public typealias Output = (Upstream.Output, Other.Output)
        public typealias Failure = Upstream.Failure

serhiybutz

func setupAdvPipeline() {
    let searchStream = searchBar.searchTextField.textPublisher
        .prepend(searchBar.text!)
        .eraseToAnyPublisher()

    let sparsedSearchStream = searchStream
        .debounce(for: .seconds(0.3), scheduler: DispatchQueue.main)
        .eraseToAnyPublisher()

    let beginRefreshingStream = refreshControl

serhiybutz

    var cancellables = Set<AnyCancellable>()

    func setupPipelines() {
        let searchStream = searchBar.searchTextField.textPublisher
            .prepend(searchBar.text!)
            .eraseToAnyPublisher()

        let sparsedSearchStream = searchStream
            .debounce(for: .seconds(0.3), scheduler: DispatchQueue.main)
            .eraseToAnyPublisher()

serhiybutz

import Combine
import Foundation

extension Publishers {
    public struct WithLatestFrom<Upstream: Publisher, Other: Publisher>: Publisher where Upstream.Failure == Other.Failure {
        // MARK: - Types

        public typealias Output = (Upstream.Output, Other.Output)
        public typealias Failure = Upstream.Failure

serhiybutz

    var cancellables = Set<AnyCancellable>()

    func setupStreams() {
        let searchStream = searchBar.searchTextField.textPublisher
            .prepend(searchBar.text!)
            .eraseToAnyPublisher()

        let sparsedSearchStream = searchStream
            .debounce(for: .seconds(0.3), scheduler: DispatchQueue.main)
            .eraseToAnyPublisher()

serhiybutz

    var cancellables = Set<AnyCancellable>()

    func setupStreams() {
        let searchStream = searchBar.searchTextField.textStream
            .prepend(searchBar.text!)
            .eraseToAnyPublisher()

        let sparsedSearchStream = searchStream
            .debounce(for: .seconds(0.3), scheduler: DispatchQueue.main)
            .eraseToAnyPublisher()

serhiybutz

import UIKit
import Combine

extension UITextField {
    var textStream: AnyPublisher<String?, Never> {
        NotificationCenter.default
            .publisher(
                for: UITextField.textDidChangeNotification,
                object: self)
            .map(\.object)