Can you explain the concept of Observable and how it is used in reactive programming?

Observable is a key concept in reactive programming, representing a data stream that can asynchronously emit values, errors, or a completion signal. An Observer subscribes to an Observable and receives updates in real time.

In Android and other platforms, this allows for convenient handling of asynchronous events, such as user input, network requests, or data changes.

Example in Kotlin using RxJava:

val observable = Observable.just("Hello", "World")
observable.subscribe(
    { item -> println("Received: $item") },
    { error -> println("Error: ${error.message}") },
    { println("Completed") }
)

Here, the Observable emits two values, which are processed in the subscribe method. This simplifies working with data streams and makes it easy to combine and transform events.