Just

Just는 가장 기본적인 Publisher 입니다.

한 개의 아웃풋을 각각의 Subscriber에게 단 한 번 보내고, 종료합니다.

다시말해서, 자신을 구독(subscribe)하는 구독자(subscriber)들에게 한번의 값만 전송하고 finish 하는 Publisher 입니다

실제 코드로 보면, Failure가 Never로 고정되어있습니다.

즉, Just는 에러를 발행할 수 없고 무조건 Output만 발행될 수 있다는것을 의미합니다.

public struct Just<Output> : Publisher {
    public typealias Failure = Never
    public let output: Output

    public init(_ output: Output)

    public func receive<S>(subscriber: S) where Output == S.Input, S : Subscriber, S.Failure == Never
}

사용

import Combine

let justPublisher = Just(5)

let subscription = justPublisher.sink { value in
    print("Received value: \\(value)")
}

// 출력값
// Received value: 5

정리

에러를 보낼 수 없다 (Failure 타입 Never)
한 번 값을 방출하면 더 이상 추가 방출이 불가능하다.
한 번 값을 방출하면 완료(.finished) 된다.

Empty

Empty는 값을 발행하지 않고 선택적으로 즉시 스트림을 종료할 수 있는 Publisher입니다.

진짜 말 그대로 아무런 값도 내보내지 않고 즉시 성공 (completion) 이벤트를 보낼수 있는 publisher 입니다.

completeImmediately

Empty에서 가장 중요한 매개변수는 completeImmediately 이라고 생각합니다.

completeImmediately는 Empty Publisher의 생성자에서 사용되는 Bool값입니다.

이 매개변수는 Empty Publisher가 생성된 직후 즉시 완료 신호를 보낼지 여부를 결정합니다.

기본값으로는 True로 설정되어있습니다.

completeImmediately: true
- Empty 퍼블리셔는 생성 즉시 완료 신호를 보냅니다.
- 구독자는 값을 받지 않고 바로 완료 이벤트를 받게 됩니다.
- 다른 퍼블리셔와 조합하여 사용할 때, 즉시 스트림을 종료시키는 효과가 있습니다.
completeImmediately: false
- Empty 퍼블리셔는 완료 신호를 보내지 않고 대기 상태를 유지합니다.
- 구독자는 어떠한 이벤트도 받지 않으며, 스트림은 계속 열린 상태로 유지됩니다.
- 다른 퍼블리셔와 조합하여 사용할 때, 스트림을 열린 상태로 유지하면서 아무 동작도 하지 않게 만듭니다.

false로 설정하면 완료 이벤트가 발행되지 않아요.

사용

import Combine

let trueEmptyPublisher = Empty<Int, Never>(completeImmediately: true)
let falseEmptyPublisher = Empty<Int, Never>(completeImmediately: false)

print("True Empty Publisher:")
let trueCancellable = trueEmptyPublisher
    .sink(receiveCompletion: { completion in
        print("Completed: \\(completion)")
    }, receiveValue: { value in
        print("Received value: \\(value)")
    })

print("\\nFalse Empty Publisher:")
let falseCancellable = falseEmptyPublisher
    .sink(receiveCompletion: { completion in
        print("Completed: \\(completion)")
    }, receiveValue: { value in
        print("Received value: \\(value)")
    })

// 잠깐만~
DispatchQueue.main.asyncAfter(deadline: .now() + 2) {
    print("\\nCancelling subscriptions")
    trueCancellable.cancel()
    falseCancellable.cancel()
}


///출력
///True Empty Publisher:
///Completed: finished

///False Empty Publisher:

///Cancelling subscriptions

즉,

completeImmediately: true로 설정된 퍼블리셔는 즉시 완료 이벤트를 발생시킵니다.

completeImmediately: false로 설정된 퍼블리셔는 아무 이벤트도 발생시키지 않습니다

정리

값을 발행하지 않고 아무런 데이터도 전송하지 않을때 사용된다.
에러타입을 ‘지정’할 수 있다 (발행아님).
completeImmediately 파라미터를 통해서 구독 직후에 완료 이벤트를 발행할 것인지 결정할 수 있다.

Fail

Fail은 에러가 나는 즉시 데이터 스트림을 종료하는 Publisher입니다.

위에서 Empty가 completion 이벤트를 즉시 보낼 수 있었다면 Fail은 Error를 즉시 보낼 수 있는 Publisher입니다

사용

import Combine

// 1. 간단한 에러 타입 정의
enum SimpleError: Error {
    case somethingWentWrong
}

// 2. Fail 퍼블리셔 생성
let failPublisher = Fail<String, SimpleError>(error: .somethingWentWrong)

// 3. 구독
let cancellable = failPublisher.sink(
    receiveCompletion: { completion in
        switch completion {
        case .finished:
            print("완료")
        case .failure(let error):
            print("에러 발생: \\(error)")
        }
    },
    receiveValue: { value in
        print("값 받음: \\(value)")
    }
)

SimpleError라는 간단한 에러 타입을 만듭니다.
Fail 퍼블리셔를 생성합니다. 이 퍼블리셔는 String 타입의 값을 발행할 수 있지만 (실제로는 발행하지 않음), SimpleError 타입의 에러를 발생시킵니다.
이 퍼블리셔를 구독합니다.

Fail 퍼블리셔는 즉시 에러를 발생시키고 종료됩니다.
값을 받는 클로저는 실행되지 않습니다.
완료 클로저에서 에러를 받아 처리합니다.

특징

오직 에러만을 발행하고 값(Output)을 발행하지 않는다.
Failure을 발행하기 때문에 즉시 스트림이 종료됩니다.

저작자표시 비영리 변경금지