Всем привет.
Есть вот такая конструкция.
private fun fetchTopTodo() {
service
.topTodo()
.subscribeOn(
Schedulers.io())
.subscribe(topTodoSubject::onNext)
.addTo(disposables)
}
Столкнулся с проблемой что topTodoSubject::onNext ни в какую не вызывается
При этом если вместо строки topTodoSubject::onNext впихнуть topTodoSubject.onNext(it), то все отрабатывает корректно.
Декомпиляция кода показала что внутри вроде как вызывается какой-то receiver на типе Function1. Либу котлина рефлексии подключил и пересобрал билд но не помогло. Разве что почистить проект и инвалидировать не пробовал