RxSwift - подписаться на метод

Есть ли способ с помощью RxSwift подписаться на метод, который возвращает блок завершения?

Например, у нас есть этот объект:

struct Service {

    private var otherService = ...
    private var initSucceeded = PublishSubject<Bool>()

    var initSucceededObservale: Observable<Bool> {
        return initSucceeded.asObservable()
    }

    func init() {
        otherService.init {(success) in
            self.initSucceeded.onNext( success)
        }
    }
}

И в другом месте есть способ получить уведомление, когда служба была инициализирована:

service.initSucceededObservable.subscribe(onNext: {
    [unowned self] (value) in
    ...
}).addDisposableTo(disposeBag)

service.init()

Есть ли решение попроще?


ios swift rx-swift
person DAN    schedule 20.02.2017    source источник

Ответы (2)


arrow_upward
0
arrow_downward

Мне нравится использовать переменные для такого рода вещей. Кроме того, я бы рекомендовал использовать здесь класс, потому что вы отслеживаете уникальные состояния, а не только заботитесь о значениях.

class Service {
    private let bag = DisposeBag()
    public var otherService: Service?

    private var isInitializedVariable = Variable<Bool>(false)

    public var isInitialized: Observable<Bool> {
        return isInitializedVariable.asObservable()
    }

    public init(andRelyOn service: Service? = nil) {
        otherService = service

        otherService?.isInitialized
            .subscribe(onNext: { [unowned self] value in
                self.isInitializedVariable.value = value
            })
            .addDisposableTo(bag)
    }

    public func initialize() {
        isInitializedVariable.value = true
    }

}

var otherService = Service()
var dependentService = Service(andRelyOn: otherService)

dependentService.isInitialized
                .debug()
                .subscribe({
                    print($0)
                })

otherService.initialize() // "Initializes" the first service, causing the second to set it's variable to true.
person dylanrw    schedule 20.02.2017

arrow_upward
0
arrow_downward

Вы можете использовать ленивое свойство:

lazy let initSucceededObservale: Observable<Bool> = {
    return Observable.create { observer in
        self.otherService.init {(success) in
            observer.on(.next(success))
            observer.on(.completed)
        }
        return Disposables.create()
    }
}()

а затем вы можете использовать:

service.init()
service.initSucceededObservable.subscribe(onNext: {
    [unowned self] (value) in
    ...
}).addDisposableTo(disposeBag)

Дайте мне знать в комментариях, если у вас возникнут проблемы, прежде чем голосовать против, спасибо.

person Marco Santarossa    schedule 20.02.2017