reactive2 [RxSwift] Observable 필터링 연산자 정리 1. debounce짧은 시간 동안 새로운 이벤트가 발생하면 이전 이벤트들을 무시하고 마지막 이벤트만 방출let subject = PublishSubject()subject .debounce(.seconds(1), scheduler: MainScheduler.instance) .subscribe(onNext: { print("Debounced: \($0)") }) .disposed(by: disposeBag)subject.onNext("A")subject.onNext("B")subject.onNext("C") // 1초 후 "C"만 출력됨2. distinctUntilChanged연속된 중복 데이터를 필터링Observable.of("A", "B", "A", "C", "B".. 2025. 2. 1. [RxSwift] Observable 생성 관련 메서드들 0. 공식 문서 먼저 정독 ReactiveX - ObservableObservable ReactiveX에서 옵저버는 Observable을 구독한다. Obseravable이 배출하는 하나 또는 연속된 항목에 옵저버는 반응한다. 이러한 패턴은 동시성 연산을 가능하게 한다. 그 이유는 Observable이 객체를reactivex.io 1. just단일 값을 발행한 후 onCompleted 이벤트 호출let observable = Observable.just("Hello, RxSwift!")observable.subscribe( onNext: { value in print(value) // 출력: Hello, RxSwift! }, onCompleted: { print(".. 2024. 12. 3. 이전 1 다음
