RxJava(2)
-
[RxJava] Combining Operators (๊ฒฐํฉ ์ฐ์ฐ์) - merge / zip / combineLatest ๋น๊ต
RxJava์ ๊ฒฐํฉ ์ฐ์ฐ์(combining operator) ์ค merge / zip / combineLatest ์ ๊ฐ ํน์ง์ ์์๋ณด๊ณ , ์ฐจ์ด์ ์ ๋น๊ตํด ์ธ์ ์ด๋ค ํจ์๋ฅผ ์จ์ผ ํ ์ง์ ๋ํด ์ค๋ช ํ๋ค. ๋ชฉ์ฐจ merge() Flattens two ObservableSources into a single ObservableSource, without any transformation == ๋ณํ ์์ด ๋ ๊ฐ์ ObservableSource๋ฅผ ํ๋์ ObservableSource๋ก ๋ณํฉํ๋ค ํน์ง์ ์๋์ ๊ฐ๋ค. ์ฌ๋ฌ๊ฐ์ ์์ค์์ ๋์ค๋ ๋ชจ๋ ์คํธ๋ฆผ์ด ๊ทธ๋๋ก ๋ฐํ๋๋ค. ์์ ๋ค์ด์ด๊ทธ๋จ์ ๋ณด๋ฉด, merge ํจ์๋ฅผ ๊ฑฐ์ณ๋ ๊ธฐ์กด ์์ดํ ์ด ๊ณ ๋๋ก ๋ฐํ๋๋ค! ํ๋์ ์์ค์์ ์๋ฌ๊ฐ ๋๋ฉด ์คํธ๋ฆผ ์์ฒด๊ฐ ์ข ๋ฃ๋๋ค ์์ ๋ค์ด..
2022.01.24 -
[RxJava] debounce vs throttle ํจ์ ์ฐจ์ด์ ๋น๊ต
์ธ ๋๋ง๋ค ํท๊ฐ๋ฆฌ๋ debounce, throttle... ์ด๋ฒ ๊ธฐํ์ ํ์คํ ์ ๋ฆฌํด ๋๊ณ , ์ ์ ๊ฐ์ด ํท๊ฐ๋ฆฌ์๋ ๋ถ๋ค์ ์ํด ๊ณต์ ํฉ๋๋ค. ์ง์ ํ ์คํธ๋ ํด๋ณด๋ ์ดํด ์์ ๋ชฉ์ฐจ debounce ํจ์ public final Observable debounce(long timeout, @NonNull TimeUnit unit, @NonNull Scheduler scheduler) { Objects.requireNonNull(unit, "unit is null"); Objects.requireNonNull(scheduler, "scheduler is null"); return RxJavaPlugins.onAssembly(new ObservableDebounceTimed(this, timeout, unit, s..
2021.09.08