Какие функции имеет Observable

Observable — это основа реактивного программирования в RxJava. Основные функции:

1. Создание – just(), fromIterable(), create(), interval()

    Observable.just("Hello")  
    Observable.fromIterable(listOf(1, 2, 3))

2. Операторы преобразования – map(), flatMap(), filter()

    Observable.range(1, 5)
        .map { it * 2 }
        .filter { it > 5 }

3. Комбинирование – merge(), concat(), zip()

    Observable.zip(obs1, obs2) { a, b -> a + b }

4. Управление потоками – subscribeOn(), observeOn()

    observable.subscribeOn(Schedulers.io())
        .observeOn(AndroidSchedulers.mainThread())

5. Обработка ошибок – onErrorReturn(), retry()

6. Подписка – subscribe() с обработкой onNext, onError, onComplete

Observable работает по принципу push-модели: данные отправляются подписчику при появлении.