[kotlin] 함수형 리액티브 프로그래밍 예시

14 Dec 2023

kotlin

함수형 리액티브 프로그래밍은 비동기 데이터 및 이벤트 기반 애플리케이션을 만드는데 유용한 패러다임입니다. 코틀린은 함수형 프로그래밍을 지원하는 언어로, 리액티브 프로그래밍에도 적합합니다.

리액티브 라이브러리 추가

리액티브 프로그래밍을 위해 ReactiveX 라이브러리를 사용할 수 있습니다. Gradle을 사용하여 의존성을 추가할 수 있습니다.

dependencies {
    implementation 'io.reactivex.rxjava2:rxkotlin:2.4.0'
}

예시: 간단한 옵저버 패턴

옵저버 패턴은 주제(서브젝트)와 각 주제를 구독하는 여러 옵저버로 구성됩니다. 주제는 상태의 변경을 모든 옵저버에게 알립니다.

import io.reactivex.Observable
import io.reactivex.Observer
import io.reactivex.disposables.Disposable

fun main() {
    val observable: Observable<String> = Observable.just("Hello, World!")

    val observer: Observer<String> = object : Observer<String> {
        override fun onSubscribe(d: Disposable) {
            println("Subscribed to $d")
        }

        override fun onNext(t: String) {
            println("Received: $t")
        }

        override fun onError(e: Throwable) {
            println("Error: ${e.message}")
        }

        override fun onComplete() {
            println("Done!")
        }
    }

    observable.subscribe(observer)
}

이 예시에서, Observable은 데이터 스트림의 공급자 역할을 하며, Observer는 이 데이터를 구독합니다.

결론

코틀린을 사용하여 함수형 리액티브 프로그래밍을 구현하는 방법에 대해 간단히 살펴보았습니다. 리액티브 프로그래밍은 비동기적인 이벤트 및 데이터 스트림을 다루는 데 유용하며, 코틀린과 ReactiveX를 결합하여 간단하게 구현할 수 있습니다.

ReactiveX Kotlin GitHub 페이지