неужели только затем чтобы сделать поток read-only, чтобы из фронта напрямую не совали внутрь что попало?

Для изоляции сабжекта

Если ты делаешь какую-то любу, и это либа будет возвращать сабжект, а не обсервабл, то потенциально можно в это сабжект пихать все что угодно из вне

понял, спасибо!

можно ли отменять репит?

или через флет мап прокинуть как-то тру/фолсе, или мб есть какой-то другой способ?

Привет! Такой вопрос, как подписать textView на изменения editText?

class MainActivity : AppCompatActivity() {
   override fun onCreate(savedInstanceState: Bundle?) {
       super.onCreate(savedInstanceState)
       setContentView(R.layout.activity_main)

       dataSource()
           .subscribeOn(Schedulers.io())
           .observeOn(AndroidSchedulers.mainThread())
           .subscribe { textView1.text = it }
   }

   private fun dataSource() = Observable.create<String> { subscriber ->
       var i: String = editText1.text.toString()
       subscriber.onNext(i)
   }
}
Работает не корректно. так как textView берет только дефолтное значение editText и походу закрывает поток

Мне как раз нужно его изобрести, я хочу понять как rx работает, я его только начал изучать

По этому и делаю кейсы небольшие саои

Есть вариант ещё лучше. Не используй для ui rx, где это возможно. Посмотри text watcher для этой задачи

А, ну тогда сори. Тогда тебе либо сабжект, как выше сказали, либо был метод для Observable, чтобы сделать из него горячий источник, сейчас вспомню

Ага, да. Смотри, тебе тут можно обойтись самым обычным Observable. Фишка в том, что ты только один раз прочитал значение, а тебе нужно получать изменения. И вот как раз для этого нужен андроидовский text watcher + Observable.create. Ты из колбэка вочера будешь onNext вызывать

Спасибо! Попробую)

Судя по документации, то да. Но лучше прыгни в сорсы и убедись, что там не создаётся новый синг-тред шедулер на каждый вызов метода

спасибо!

Привет.
Имеется BehaviorSubject, нужен Single, в котором либо будет just(текущее значение), либо когда-нибудь приедет следующее.
Как это можно сделать? Вижу singleOrError(), но выглядит совершенно бесполезно, т. к. не умеет дожидаться элемента.

звучит как take(1)

в каком смысле не умеет дожидаться? subject на своем потоке выполнения, а ты ждёшь в main, который завершается?

в джавадоке написано, что если значения нет, то сразу будет ошибка

тогда получится Observable :)