RxSwift - ReactiveX

contents

🟣 ReactiveX

🟣 반응형 프로그래밍

🟣 함수형 프로그래밍

🟣 참고 자료

ReactiveX

ReactiveX(RX)는 크게 3가지 요소로 구성됩니다.

⓵ 일련의 값들을 발행해내는 Observable

⓶ 연속적인 값들이 흘러가는 Stream에서 Pipe 역할을 하는 Operator

⓷ Pipe만 쳐다보며 값을 기다리다가 무언가가 나오면 작업을 진행하는 Observer

3가지 요소를 로봇 공장으로 설명해볼게요.

Observable은 값을 찍어내서 Stream 위에 올려주는 기계입니다. Observable은 들어온 데이터를 Stream, “흐름” 에 흘려보냅니다. 여기서 Stream을 컨베이어 벨트라고 부를게요.

우리는 Observable이라는 기계에서 찍어낸 데이터 로봇을 Stream이라는 컨베이어 벨트에 올려주게 됩니다.

Observable 기계에서 찍어낸 데이터 로봇들은 컨베이어 벨트를 타고 이동하게 됩니다.

이동 중에 filter 라는 Operator를 만나게 됩니다. 해당 Operator는 이름 그대로, 데이터 로봇들을 걸러내는 역할을 합니다. 우리가 만난 filter 는 색깔을 걸러내는 역할을 합니다.

filter 파이퍼로 걸러진 데이터 로봇은 map 이라는 Operator를 만납니다. 해당 Operator 안에 있는 포장하기 메서드로 인해서 데이터 로봇은 포장됩니다.

Observable에 의해서 만들어지고 Operator에 의해서 걸러지고 꾸며진 데이터 로봇은 해당 공장에서 나오는 제품을 기다리고 있는 Observer에게 갑니다. Observer는 자신이 가지고 있는 가방에 해당 제품을 받길 원합니다.

Rx는 데이터를 하나의 흐름으로 흘려보내면서 중간 중간 Operator를 통해 데이터를 꾸며주거나 걸러내기도 하면서 데이터를 받길 원하는 누군가에게 데이터를 전달해줍니다.

근데, Operator같은 경우에는 기본적인 컴퓨터 언어에서 제공해줍니다. Rx를 사용하지 않더라도 map, filter 메서드를 사용해서 값을 처리할 수 있습니다.

그러면, Rx는 무슨 이점이 있는건가요?

1차원적인 값뿐만 아니라 시간의 흐름, 사용자의 동작, 네트워크 요청의 결과를 전부 Stream으로 만들어서 보낼 수 있습니다.

Integer, String등의 타입말고도 사용자가 버튼을 탭한 경우, 사용자가 스크롤을 했을 때같은 사용자의 동작도 Stream에 담아서 보낼 수 있습니다. 또한, Operator를 사용해서 그 값을 가공할 수도 있는거죠.

Stream을 통해서 나오는 값은 해당 Observable를 구독하고 있는 Observer가 처리합니다. 위에서 Stream을 통해서 “값이 나오면 해당 값을 가방에 넣어라” 처럼 자신의 상황에 맞게끔 처리합니다.

Rx같이 데이터의 흐름과 변경 사항의 전파에 중점을 둔 선언적 프로그래밍 패러다임을 반응형 프로그래밍이라고 합니다.

반응형 프로그래밍

Reactive = Change Dection + Binding + Template + Auto Render

반응형 프로그래밍에서는 값이 변경되었을 때, 템플릿에 선언해둔대로 알아서 화면이 렌더링됩니다.

이전에는 렌더링 시점에 필요한 데이터를 모두 불러와서 화면에 출력했습니다. 하지만, 반응형 프로그래밍을 하는 경우에는 미리 선언되어 있는 구조에서 값이 변화하면 템플릿으로 데이터를 전달합니다.

즉, 이전에는 데이터를 가져와서 화면을 만들었다면, 현재는 무엇을 할 지 선언하여 변경된 데이터를 감지하고 전파합니다.

그렇기 때문에, 반응형 프로그래밍은 비동기 프로그래밍을 잘하기 위해서 필요합니다.

비동기 프로그래밍을 잘하는 것은 중요합니다. 화면이 사용자의 의도로 어떻게 동작할 지 예측 불가하고, 서버의 응답이 언제 어떻게 올 지 예측 불가한 상황에서 비동기 프로그래밍을 잘 다룰 줄 안다면 예측 불가한 상황을 잘 헤쳐나갈 수 있습니다.

하지만, 비동기 프로그래밍은 어렵습니다.

비동기 프로그래밍을 하게 되면 작성한 코드가 순서대로 동작하지 않습니다. 언제 실행될 지 예측할 수 없고, 호출한 순서로 동작한다는 보장도 없습니다. 또한, 호출 당시 값, 실제 실행되었을 때 값이 그대로라고 보장할 수도 없습니다.

예측할 수 없는 비동기 프로그래밍이 복합적으로 존재한다면 코드를 작성하기 더 힘들어질겁니다. 예를 들어서, 사용자가 카카오 로그인 버튼을 눌렀다고 해봅시다. 버튼을 누르면 카카오 서버에 해당 사용자가 유효한 사용자인지 확인합니다. 자체 서버에서 한 번 더 해당 사용자가 유효한 사용자인지 확인합니다. 두 서버 모두에서 OK인 상황이라면 로그인을 시켜주는 로직을 짠다고 해봅시다.

버튼을 눌렀을 때 카카오 서버와 자체 서버 모두에 비동기적으로 유효한 사용자인지 확인을 하고, 반환되는 값이 OK인지 확인해서 로그인 완료 처리한 후에 앱에 입장할 수 있게끔 하는 로직, 생각만 해도 복잡하지 않나요?

이런 상황에서 이벤트 리스너의 관점에서 프로그래밍을 한다면 어려움이 해결됩니다.

반응형 프로그래밍은 데이터 흐름과 변경사항 전파에 중점을 둔 선언적 프로그래밍이라고 했습니다. 모든 것을 Stream으로 간주하고 선언적으로 개발을 하는거죠.

비동기를 조금 더 간결하게 바라볼 수 있는 관점이 제공됩니다.

RxSwift로 위의 상황을 작성한다고 했을 때, Rx는 사용자의 동작마저도 Stream으로 만들어서 보낼 수 있기에 사용자가 카카오 로그인 버튼을 눌렀다는 동작을 Stream으로 보낼겁니다.

kakaoLoginButton.rx.tap
Swift
복사

그리고, 사용자의 정보가 유효한지에 대한 값을 받아서, 둘 다 True 값이 들어오는지 확인하겠죠.

.filter { kakaoAPI.checkUser() && appAPI.checkUser() }
Swift
복사

해당 필터에서 걸러지지 않았다면 유효한 사용자이기 때문에 메인 화면으로 넘어갈 수 있을 겁니다.

.subscribe { _ in 
		presentMainScreen() 
}
Swift
복사

보시다시피, Rx의 흐름은 한 방향의 화살표로 나타낼 수 있습니다. 그렇기 때문에, 비동기 흐름을 단순한 형태로 바라볼 수 있게 되는거죠. 이해하기 쉽습니다.

또한, 선언형 프로그래밍 방식으로 코드가 작성되어 있어서 각 부분이 서로를 알지 못해도 괜찮고, 변수로 인해서 오류가 날 위험이 적습니다.

함수형 프로그래밍

프로그래밍 패러다임 에서 함수형 프로그래밍과 프로그래밍 패러다임에 대한 내용을 조금 더 자세히 작성해뒀습니다. 해당 포스팅을 보고나서 나머지 내용을 보는걸 추천드립니다.

함수형 프로그래밍은 오류를 만들어내는 변수의 사용을 지양합니다. 따라서, 순수 함수를 사용해서 프로그래밍을 하게 됩니다. 순수 함수는 같은 입력을 넣었을 때, 항상 같은 출력 값을 내보내는 함수로 외부의 변수를 사용하지 않습니다.

외부의 변수를 사용하지 않으면 변수로 인해서 함수가 예측하지 못한 값을 리턴하지 않기 때문에 Side-effect가 사라집니다. 프로그래머의 착오로 인한 오류, 스레드 동시 접근에 의한 오류, 교착 문제로부터 자유로운 프로그래밍이 가능해지게 됩니다.

Rx는 함수형 프로그래밍의 기본 골격을 갖추고 있습니다.

작업을 진행하는데 있어서 단 하나의 변수도 사용하지 않고, subscribe 코드를 제외하고는 오직 흐름을 생성하고 조립해서 상수로 선언하는 것만으로 코드가 구성되어 있기 때문이죠.

또한, 각 부분이 서로를 알지 못하기 때문에 다른 부분이 변경될 때 받는 영향이 최소화됩니다.

가독성, 재사용성, 독립성, 유지보수성 면에서 좋은 코드라고 볼 수 있는겁니다.

참고 자료

•

반응형 프로그래밍이 뭔가요? (+ ReactiveX 강좌)

•

프로그래밍 패러다임과 반응형 프로그래밍 그리고 Rx