RxSwift(5)-TimeBasedOperators
·
반응형프로그래밍
시간에 기반한 오퍼레이터-> 시간 흐름을 지연시켜주거나 제어Buffering OperatorsBuffering 연산자들은 Observable 시퀀스에서 방출된 이벤트들을 일정 기간 동안 모았다가 한 번에 처리할 수 있게 해줍니다. 이를 통해 과거 이벤트를 재생하거나 일정 시간 동안 버퍼링하는 기능을 구현할 수 있습니다.Replay(_:)새로운 구독자에게 과거에 방출된 요소들의 일부를 다시 전달합니다// 마지막 N개의 이벤트를 새 구독자에게 전달let replayedObservable = Observable.interval(1,scheduler: .instance).replay(2)// 첫 번째 구독자replayedObservable.subscribe(onNext: { value in print("첫..
RxSwift(3)-Filtering Operators & TransForming Operators
·
반응형프로그래밍
next 이벤트를 통해 넘어온 값들에 대해 필터를 해줘 해당 오퍼레이터를 통해 넘어온 값들에 대해 다 처리하지 않고 원하는 값만 골라 처리할 수 있어지는 기능에 대해 살펴보겟습니다이것도 4가지 종류가 있습니다.. 자주 나오는것 같다 4.4..1. Ignoring OperatorignoreElement()값들이 방출되어도 무시되고 스트림에 등록되지 않는다. 하지만 error나 completed는 무시하지 않습니다.example(of: "ignoreElements") { // 1 let strikes = PublishSubject() let disposeBag = DisposeBag()// 2 strikes .ignoreElements() .subscribe { _ in print..