'rxswift' 태그의 글 목록

2023. 7. 26. 00:41 iOS/RxSwift

Signle은 RxSwift의 Traits로 하나의 이벤트만 방출하는 Observable이다. Single에는 failure, success라는 2가지 이벤트가 존재한다. success는 일반 Observable의 next + completed와 같은 역할이고 failure은 error이벤트와 같은 역할이다. 다음과 같이 초기에 한번만 이루어지는 네트워크 요청에 자주 사용된다. static func featchAllData(_ url: String) -> Single { return Single.create { single in URLSession.shared.dataTask(with: URL(string: url)!) { data, res, err in if let err = err { single(...

[RxSwift] Relay vs. Signal vs. Driver

2023. 7. 25. 22:41 iOS/RxSwift

RxSwift를 사용해서 UI작업을 할 때 RxCocoa에 존재하는 Relay, Signal, Driver를 많이 사용하곤 한다. 이 3개의 차이점에 대해서 알아보자. Relay Relay는 Subject의 Wrapper Class이다. 이는 completed, error이벤트를 무시하며, next이벤트만 Subscriber에게 전달한다. UI Update를 위해 사용하는 Subject가 error 혹은 completed이벤트로 스트림이 끊기면 안 되기 때문에, Relay는 UI작업에 특화된 Subject이다. 더 자세한 내용은 해당 포스팅에 있으니 참고 바란다. Driver & Signal Driver와 Signal은 RxCocoa의 Trait로 Main Thread에서 동작하는 것을 보장하며, err..

[RxSwift] Operator(4) - Share

2023. 7. 24. 22:54 iOS/RxSwift

Observable은 구독되기 전까지는 동작하지 않다가, 구독이 이루어지면 한 번에 데이터를 방출한다. 이걸 Cold Observable이라 한다. Cold Observable은 UnitCast방식으로 동작하여, Subscriber마다 하나의 Stream이 생성이 된다. 반면 Subject와 같은 Hot Observable은 Multicast방식으로 동작하며, 하나의 Stream을 통해 데이터가 방출된다. 이 내용이 이해되지 않는 다면, 해당 포스팅을 보길 바란다. 하나의 Stream을 통해 데이터가 방출되는 Hot Observable과 달리 Subscriber마다 Stream이 생성되는 Cold Observable에서는 Stream이 여러개 생길 수 있다. 다음과 같은 함수가 있다고 가정해 보자. fu..

[RxSwift] Operator(3) - Combining

2023. 1. 8. 19:12 iOS/RxSwift

이번 포스팅에서는 sequence들을 모으고, 여러 sequence내의 데이터들을 병합하는 방법에 대해 알아보자. startWith(_:) subscriber가 Observable을 구독하고, 요소를 방출받을 때 초기값을 지정해 주는 연산자이다. Observable의 타입과 초기값의 타입이 같아야 한다. let observable = Observable.of("A", "B", "C") observable .startWith("alphabet will start to emit") .subscribe( onNext: { print($0) } ) .disposed(by: disposBag) /* prints: alphabet will start to emit A B C */ concat(_:) concat은 ..

[RxSwift] Traits

2022. 12. 28. 16:47 iOS/RxSwift

Traits란 기존의 Observable의 wrapper 구조체로, 더 제한적인 기능을 수행하는 Observable이다. public typealias Single = PrimitiveSequence public typealias Completable = PrimitiveSequence public struct PrimitiveSequence { let source: Observable init(raw: Observable) { self.source = raw } } 즉, Observable보다 좁은 범위의 기능을 수행하기에, Traits를 사용하지 않고 Observable로 커버가 가능하지만, 코드가 더 명확해진다는 장점이 있다. Single 기존 Observable에서는 next, completed,..

[RxSwift] Operator(2) - Transforming

2022. 12. 27. 18:35 iOS/RxSwift

이번 포스팅에서 살펴볼 연산자는 Observable을 통해 방출되는 item들을 변형해주는 연산자에 대해 알아보자. toArray onCompleted 이벤트 전까지, next 이벤트를 통해 전달된 데이터를 배열로 묶어 한번에 방출한다. toArray() 연산자를 거치게 되면, Single 타입으로 바뀌게 된다. Single 타입은 success, failture이벤트만 전달하기 때문에, subscribe 메서드에서 onCompleted, onNext 가 아닌 onSuccess, onFailure를 통해 이벤트를 받는다. let publish = PublishSubject() publish .toArray() // Single 타입으로 리턴됨. .subscribe( onSuccess: { print($0..

[RxSwift] Operator(1) - Filtering

2022. 12. 25. 15:16 iOS/RxSwift

이번 포스팅에서는 RxSwift의 Operator중에서 Filtering에 관련된 Operator들에 대해 알아보자. Filtering Operator를 통해 next 이벤트를 통해 받는 데이터를 선택적으로 취할 수 있다. Ignoreing Operators ignoreElements() 마블 다이어그램을 보면 알 수 있듯이, next를 통해 전달된 모든 데이터를 무시한다. 여기서 주의할 점은 next를 통해 들어온 이벤트만 무시하고, completed, error 이벤트들은 정상적으로 전달되어 스트림이 끊기게 된다. //Cold Observable의 경우 func observable() -> Observable { return Observable.create { observer in observer.o..

[RxSwift] Subjects

2022. 12. 1. 01:29 iOS/RxSwift

이번 포스팅에서 알아볼 Subject를 알아보기에 앞서, HOT Observable과 COLD Observable에 대해 알아보자! Cold Observable & Hot Observable Cold Observable이란 구독이 되기 전까지 동작하지 않다가, 구독이 되면, 모든 데이터를 한번에 방출한다. Cold Observable을 marble diagram으로 표현하면 아래와 같다.(점선은 구독을 의미한다) 지금까지 알아보았던 Observable이 Cold observable이다. 또한, Unicast방식으로 동작하여, Subscriber(Observer)마다 고유의 Stream이 생성된다. Hot Observable은 구독 여부와 상관없이 방출할 데이터가 있으면 방출한다. 구독이 되면, 모든 데이..

[RxSwift] Observable(2) - Creating Observable

2022. 11. 28. 00:21 iOS/RxSwift

이번 포스팅에는 Observable을 생성하는 Operator 몇 가지에 대해 알아보자! Marble Diagram Operator를 이해하기 앞서, 이 marble diagram에 대해 알 필요가 있다. 실제 ReactiveX에 들어가서 여러 Operator들을 보게 되면, Operator들의 동작을 Marble Diagram을 통해 표현한다. .just() 우선, marble diagram 부터 살펴보자 just 연산자는 marble diagram으로 이해해보면, 데이터가 들어와서(빨간 구슬), Just Operator를 거치게 되면, 데이터를(빨간 구슬)을 방출하는 Observable을 생성하고, 바로 Completed된다. let observable = Observable.just(1) //Obs..

[RxSwift] Observable(1)

2022. 11. 27. 01:03 iOS/RxSwift

이번 포스팅에서는 RxSwift에서 핵심이라고 할 수 있는 Observable에 대해서 알아보자 Observable의 사전적 정의는 "관찰 가능한" 인데, 저번 포스팅에서 말했듯이, Observable은 관찰 가능한 시퀀스를 통해! 이벤트를 방출 한다. 이러한 이유 때문에, RxSwift에서는 이 Observable을 sequence, Observable Sequence라고도 부른다. Observable은 이 이벤트를 방출할때, 비동기로 이벤트를 방출한다! Observable 생명 주기 우선 Observable은 3가지 종류의 이벤트를 방출 할 수 있는데, next error completed 실제 Observable의 이벤트를 보면 @frozen public enum Event { /// Next el..

[RxSwift] RxSwift란?

2022. 11. 25. 01:37 iOS/RxSwift

Rx란, Reactive eXtension의 줄임말로, Observable(관찰 가능한) 시퀀스를 사용하여, 비동기식 프로그램 혹은 이벤트 기반 프로그램을 구성하기 위환 오픈 소스 라이브러리이다. 또한, 이런 관찰 가능한 시퀀스를 지원하기 위해 Observer 패턴을 사용한다. 아마 해당 문장의 이해가 쉽지 않을 것이다. 이제 이 문장을 천천히 이해해보자! 비동기 프로그래밍 네트워크 통신과 관련한 로직을 "동기적" 으로 짜게 되면, 아래와 같이 앱의 UI업데이트가 멈추는 현상을 발견할 수 있다. 이러한 이유 때문에, 비동기 프로그래밍이 중요한데, 위의 예시를 GCD와 Closure를 통해 비동기 방식으로 짜게 되면, func downLoadJson(_ url: String, _ completionHand..

티스토리툴바