Buffer

    [rxSwift] TimeBased Operator 의 종류

    [rxSwift] TimeBased Operator 의 종류

    TimeBased Operator 의 종류 replay 구독자가 과거의 요소들을 자신이 구독하기 전에 나왔던 이벤트들을 버퍼의 갯수만큼 최신 순서대로 받게 함. replay관련 연산자를 사용할 땐 꼭 connect()로 연결해주어야 함. replay(bufferSize)에 1을 작성했다면 구독 전 가장 최신으로 배출된 item 1개를 받음. let hi = PublishSubject() let parrot = hi.replay(1) parrot.connect() hi.onNext("hi") hi.onNext("hello") parrot .subscribe(onNext: { print($0) }) .disposed(by: disposeBag) hi.onNext("good") // hello // good ..