# RxJava

iamjm29

RxJava2 를 사용하면서 이것 저것 적용해보다가 RxJava2CallAdapterFactory 라는 메서드를 적용하게 되었다. squareup에서 제공하는 retrofit과 rxjava의 adapter 라이브러리를 추가하여 사용할 수 있다.위 코드는 Hilt의 모듈

jiwon3378

Observable 클래스와 그의 파생 클래스에 대해 알아보자

dongbin98

나만 몰랐던 RxJava 이제라도 알아보자

jiwon3378

이번 포스팅에서는 리액티브 프로그래밍의 개념과 자바 언어로 구현한 RxJava 라이브러리를 소개할 예정이다.

yys7517

Java를 사용하여 Reactive Programming을 하게 해주는 RxJava에 대해서 공부해보았다.

nohjunh

https://developer.android.com/kotlin/coroutineshttps://inf.run/gFt8CoroutinesAndroid의 비동기 프로그래밍에 권장되는 Solution코루틴= 비동기적으로 실행되는 코드를 간소화하는 동시

thsamajiki

RxJava는 Observable과 유사한 “Single”을 제공한다.Single은 Observable의 변형된 형태이다. Observable과 비슷하지만, 여러 개의 데이터를 발행할 수 있는 Observable과 달리 Single은 한 개의 데이터(혹은 에러)만을 발

heetaeheo

Observable의 경우 생산자 역할을 하고, Observer는 소비자 역할을 합니다. Observable에서는 생산과 소비가 각각 따로 동작하기 때문에 만약 Observer의 데이터 처리속도가 느린 경우 생산은 대량으로 진행되고 소비는 천천히 일어나는 상황을 마딱드

wonseok

📌 RxJava vs RxKotlin 안드로이드 앱을 개발하고 있는 여러분에게는 이런 의문점이 생길 것이다. "나는 분명히 코틀린을 사용하고 있는데 왜 RxJava에 대한 글을 읽고 있지?" 좋은 질문이다! RxJava는 코틀린이 주류 프로그래밍 언어로 인정받기

heetaeheo

RxJava / RxKotlin은 try-catch문을 사용할 수 없고 로그를 넣을 수 있는 공간이 없기 때문에 doOnXXX() 계열의 함수를 이용하여 강제로 부수 효과를 일으켜 디버깅(Debugging)처리를 합니다. doOnEach() 데이터가 발행되기 직전에

hyerin0930

refreshToken을 드디어 배웠다!refreshToken 셋팅이 이 정도로 어려울 줄이야?refreshToken 셋팅에 Apollo-client의 onError()를 활용하는데, onError()의 return 타입이 observable이라고 한다.넹 observ

heetaeheo

Observer나 Subscriber 객체에 onError() 함수를 override하면 생산자에서 발생하는 error를 전달받을 수 있습니다. Observable에서 에러가 발생하면 Emitter.onError() 이벤트를 발행하는 것을 설명한 적 있습니다. subs

heetaeheo

여러 개의 Observable 데이터 스트림을 하나의 Observable로 만들 수 있습니다. 여러 데이터를 이용하여 가공해서 사용하는 경우, 혹은 HTTP 통신의 응답들을 한 번에 묶어서 받고 싶은 경우 등에 사용하게 됩니다. combineLast()는 두 Obser

heetaeheo

이번 글에서는 필터 연산자들을 이용해 원하는 값들 만을 걸러내는 기능들을 구현해보겠습니다.filter()의 경우 발행되는 데이터 스트림에서 특정 연산식의 조건에 부합하는 아이템들만 발행해주는 연산자입니다.즉 조건의 부합되지않는 데이터는 제거해주고 원하는 데이터만 정의한

heetaeheo

RxJava에서는 아이템을 그대로 발행하는 것 뿐 아니라, 발행되는 아이템을 변환하여 다른 아이템으로 변경할 수 도 있습니다. Map은 발행되는 아이템을 변환하는 가장 기본적인 방법으로 발행된 아이템에 원하는 수식을 적용하거나 다른 방법으로 변환시킬 수 있습니다. ma

heetaeheo

이전의 글에서 create()와 just()을 이용하여Observable을 생성하는 방법에 대해서 알아보았습니다. 하지만 RxJava에는 그것보다 더 많은 생성방법이 존재했습니다. 그렇기에 조금 더 알아보는 글을 작성해보려고 합니다. defer()로 생성된 Observ

heetaeheo

이전 포스트들에서 Observable 객체에서 발행할 아이템을 정의한 후 subscribe()를 통해 스트림을 생성하고 아이템을 발행했습니다. 이 subscribe()를 호출한 후에는 Disposable 객체가 반환됩니다.코드 Observable이 발행하는 아이템의 개

heetaeheo

Cold Observable은 다음과 같은 특징을 가지고 있습니다. 일반적인 옵저버 형태를 말합니다. 누가 구독해주지 않으면 데이터를 배출해주지 않습니다. 일반적인 웹 요청, 데이터베이스 커리 등이 사용되며 내가 요청하면 결과를 받는 과정을 거칩니다.처음부터 발행하는

heetaeheo

Single은 Observable의 변형된 형태입니다. Observable과 비슷하지만, 여러 개의 데이터를 발행할 수 있는 Observable과 달리 Single은 한 개의 데이터(혹은 에러)만을 발행합니다. Observable은 3가지 알림을 보내지만 Single은