ramunasjurgilas

["L", "I", "E", "T", "U", "S", "!"]
    .publisher.collect().sink {
    print($0)
}
// Output: ["L", "I", "E", "T", "U", "S", "!"]

["L", "I", "E", "T", "U", "S", "!"]
    .publisher.collect(4).sink {
    print($0)
}

ramunasjurgilas

["1", "2", "w", "3"]
    .publisher.map {
        Int($0)
}
.sink {
    print($0)
}

// Output:
//Optional(1)

ramunasjurgilas

struct Person {
    let firstName: String
    let lastName: String
}

let publisher = PassthroughSubject<Person, Never>()

publisher
    .map(\.firstName, \.lastName).sink {
    print("\($0) \($1)")

ramunasjurgilas

struct Person {
    var name: String
    let age: CurrentValueSubject<Int, Never>

    init(name: String, age: Int) {
        self.name = name
        self.age = CurrentValueSubject(age)
    }
}

ramunasjurgilas

[1, nil, 3]
    .publisher
    .replaceNil(with: -1)
    .sink { print($0) }

// Output:
//  Optional(1)
//  Optional(-1)
//  Optional(3)

ramunasjurgilas

let empty = Empty<String, Never>()

empty
    .replaceEmpty(with: "Replaced")
    .sink(
        receiveCompletion: { print($0) },
        receiveValue: { print($0) }
)

// Output:

ramunasjurgilas

(1...4)
    .publisher
    .scan([]) { (values, value) -> [String] in
        values + [String(value)]
}
.sink { print($0) }

// Output:
//    ["1"]
//    ["1", "2"]

ramunasjurgilas

"KoBrA"
    .publisher
    .filter { $0.isUppercase }
    .sink { print($0) }

// Output:
//    K
//    B
//    A

ramunasjurgilas

[1,1,2,1,1,3]
    .publisher
    .removeDuplicates()
    .sink { print($0) }

// Output:
//    1
//    2
//    1
//    3

ramunasjurgilas

["1", "a", "3.5", "2,5"]
    .publisher
    .compactMap { Double($0) }
    .sink { print($0) }

// Output:
//    1.0
//    3.5