Наблюдаемые для выбора - RxSwift

Question

Я пытаюсь перенести мое FRP понимание от ReactiveCocoa 2,5 к RxSwift и у меня есть одно недоразумение. В ReactiveCocoa я использовал rac_signalForSelector, когда захотел наблюдать вызов метода. Есть ли способ реализовать эту логику с помощью RxSwift?

Я написал небольшой пример, в котором я хочу распоряжаться подпиской при вызове метода test. Но в блоке подписки я все еще вижу событие next(6). Что я делаю не так?

let subject = PublishSubject<Int>() 
subject.takeUntil(self.rx.sentMessage(#selector(test))).subscribe { event in 
    print(event) 
} 

subject.onNext(3) 
test() 
subject.onNext(6) 

////////////////// 

func test() { 

} 

Answer 1

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

class ViewController: UIViewController { 

    let disposeBag = DisposeBag() 

    override func viewDidLoad() { 
     super.viewDidLoad() 

     self.rx.sentMessage(#selector(UIViewController.viewWillAppear(_:))) 
      .subscribe({ e in 
       print(e) 
      }) 
      .addDisposableTo(disposeBag) 
    } 
} 

Выходы:

следующая ([0])

Или другой пример:

class SomeNSObjectClass: NSObject { 
} 

class ViewController: UIViewController { 

    let disposeBag = DisposeBag() 

    override func viewDidLoad() { 
     super.viewDidLoad() 

     let myObj = SomeNSObjectClass() 
     myObjc.rx.sentMessage(NSSelectorFromString("dealloc")) 
      .subscribe({ e in 
       print(e) 
      }) 
      .addDisposableTo(disposeBag) 
     } 
    } 
} 

Выходы:

следующая ([])
завершено

Answer 2

вы должны использовать dynamic модификатор для test функции, доступ к test функции никогда не встраиваются или devirtualized компилятором.

так: dynamic func test() {}

Answer 3

Я добавляю этот комментарий после встречи с той же проблемой, но теперь я решил.

Решение для меня, - Прошу прощения, если это не то, что вы ищете, но надежда поможет другим с той же проблемой, - просто добавлял модификатор dynamic для наблюдаемой функции.

Это код

func viewDidLoad() { 
    rx.sentMessage(#selector(ViewController.test)) 
     .debug("Test", trimOutput: true) 
     .subcribe() 
     .disposed(by: bag) 
} 

@objc dynamic test() {} 

dynamic Без модификатора вызов теста не наблюдается, потому что отладка ничего не печатает.

Я новичок в RxSwift.

Спасибо @zhongwuzw выше, я получил идею после прочтения его комментария.