[RxCocoa] bind란?

안녕하세요 Foma 👟 입니다!

 

오랜만에 Rx관련 포스팅을 하네요.

 

오늘은 UI 특화된 Operator 중 bind에 대해서 알아보려고 합니다.

 

바로 시작할게요~

---

Binder 

 

먼저 bind를 이해하기 위해선 Binder를 알아야 하는데요.

 

Binder는 옵저버 타입으로 3가지 특징이 있는데요.

 

첫 번째로는 반드시 메인스케쥴러에서 실행된다는 것입니다.

 

두 번째로는 에러 이벤트를 따로 방출하지 않고 로그로만 출력됩니다.

 

세 번째로는 옵저버타입이기 때문에 새로운 값을 전달할 수 있지만 구독자를 추가할 수는 없습니다.

 

public struct Binder<Value>: ObserverType {
    public typealias Element = Value
    
    private let binding: (Event<Value>) -> Void

    /// Initializes `Binder`
    ///
    /// - parameter target: Target object.
    /// - parameter scheduler: Scheduler used to bind the events.
    /// - parameter binding: Binding logic.
    public init<Target: AnyObject>(_ target: Target, scheduler: ImmediateSchedulerType = MainScheduler(), binding: @escaping (Target, Value) -> Void) {
        weak var weakTarget = target

        self.binding = { event in
            switch event {
            case .next(let element):
                _ = scheduler.schedule(element) { element in
                    if let target = weakTarget {
                        binding(target, element)
                    }
                    return Disposables.create()
                }
            case .error(let error):
                rxFatalErrorInDebug("Binding error: \(error)")
            case .completed:
                break
            }
        }
    }

---

bind란? 

 

Binder 옵저버를 사용해서 UI와 옵저버블을 하나로 묶는 행위입니다.

 

쉽게 설명하면 Observable이 이벤트를 방출하고 subscribe를 통해 관찰을 했죠?

 

bind는 옵저버블과 관찰하는 옵저버를 그냥 하나로 묶어버리는 것이죠.

 

만약 레이블의 텍스트를 옵저버블이 방출한 이벤트대로 바꾸고싶다면 아래와 같이 코드를 작성할 수 있습니다.

 

 observable.subscribe{
	self.label.text = $0
	}.disposed(by: disposeBag)

 

하지만 bind를 사용하게 되면 아래와 같이 방출한 이벤트 그대로를 label의 텍스트와 bind 해줘버리는 것이죠!

 

(bind는 값을 전달하기만 하기 때문에 관찰을 할 수는 없습니다.)

 

observable
	.bind(to: label.rx.text)
	.disposed(by: disposeBag)

 

bind 내부 코드는 아래와 같이 subscribe를 통해서 이벤트를 관찰하고 있습니다.

 

public func bind<Observer: ObserverType>(to observers: Observer...) -> Disposable where Observer.Element == Element {
        self.subscribe { event in
            observers.forEach { $0.on(event) }
        }
    }

 

만약 에러가 생겼다면 bind는 에러를 방출하지 않고 로그로 출력해줍니다.

 

public func bind(onNext: @escaping (Element) -> Void) -> Disposable {
        self.subscribe(onNext: onNext,
                       onError: { error in
                        rxFatalErrorInDebug("Binding error: \(error)")
                       })
    }

 

UIButton과 title을 rx로 바인딩할 때 실제로 Binder를 return하는 것을 볼 수 있습니다.

 

extension Reactive where Base: UIButton {
    /// Reactive wrapper for `setTitle(_:for:)`
    public func title(for controlState: UIControl.State = []) -> Binder<String?> {
        Binder(self.base) { button, title in
            button.setTitle(title, for: controlState)
        }
    }

---

정리

 

bind는 UI와 옵저버블을 묶는 행위로 값을 전달하기만 하며 메인 쓰레드에서 작동하고 에러를 방출하지도 않는다.