Можете объяснить концепцию Observable и как она используется в реактивном программировании?

Observable — это ключевая концепция реактивного программирования, представляющая собой поток данных, который может асинхронно эмитировать значения, ошибки или сигнал завершения. Наблюдатель (Observer) подписывается на Observable и получает обновления в реальном времени.

В Android и других платформах это позволяет удобно работать с асинхронными событиями, например, с пользовательским вводом, сетевыми запросами или изменениями данных.

Пример на Kotlin с использованием RxJava:

val observable = Observable.just("Привет", "Мир")
observable.subscribe(
    { item -> println("Получено: $item") },
    { error -> println("Ошибка: ${error.message}") },
    { println("Завершено") }
)

Здесь Observable эмитирует два значения, которые обрабатываются в методе subscribe. Это упрощает работу с потоками данных и позволяет легко комбинировать и трансформировать события.