El tudná magyarázni az Observable fogalmát és hogyan használják a reaktív programozásban?

Observable — a reaktív programozás egyik kulcsfogalma, amely egy adatfolyamot képvisel, amely aszinkron módon képes értékeket, hibákat vagy befejezési jeleket kibocsátani. A megfigyelő (Observer) feliratkozik egy Observable-re, és valós idejű frissítéseket kap.

Androidon és más platformokon ez lehetővé teszi az aszinkron események, például felhasználói bemenet, hálózati kérések vagy adatmódosítások kényelmes kezelését.

Kotlin példával RxJava használatával:

val observable = Observable.just("Szia", "Világ")
observable.subscribe(
    { item -> println("Kaptuk: $item") },
    { error -> println("Hiba: ${error.message}") },
    { println("Befejeződött") }
)

Itt az Observable két értéket bocsát ki, amelyeket a subscribe módszer kezel. Ez megkönnyíti az adatfolyamokkal való munkát, és lehetővé teszi az események könnyű kombinálását és transzformálását.