Вот пример использования наблюдаемых в Kotlin вместе с некоторыми распространенными методами:

import io.reactivex.rxjava3.core.Observable
fun main() {
    val observable = Observable.create<String> { emitter ->
        emitter.onNext("Hello")
        emitter.onNext("World")
        emitter.onComplete()
    }
    observable.subscribe(
        { value -> println("Received: $value") },
        { error -> println("Error: $error") },
        { println("Completed") }
    )
}

В этом примере мы используем библиотеку RxJava для создания наблюдаемой последовательности строк. Метод Observable.createпозволяет нам определить последовательность событий. В этом случае мы выдаем два значения («Привет» и «Мир»), а затем завершаем последовательность.

Затем мы подписываемся на наблюдаемое, используя метод subscribe. Первый аргумент — это лямбда, которая обрабатывает значения, выдаваемые наблюдаемым объектом (onNext), второй аргумент обрабатывает любые возникающие ошибки (onError), а третий аргумент называется когда наблюдаемое завершается (onComplete).

Некоторые другие распространенные методы, которые вы можете использовать с наблюдаемыми:

• map: преобразует каждый созданный элемент, применяя к нему функцию.
• фильтр: фильтрует выдаваемые элементы на основе условия.
• flatMap: преобразует каждый созданный элемент в другой наблюдаемый объект и объединяет результаты.
• distinct: фильтрует повторяющиеся элементы, выдаваемые наблюдаемым объектом.
• take: генерирует только первые элементы n, созданные наблюдаемым объектом.

С помощью этих методов вы можете манипулировать и преобразовывать выдаваемые значения различными способами.