easyvvon
@easyvvon
Reviews Written
15
Average Rating
4.8
Posts
Q&A
XML์ด๋ data set์ ์ฌ์ฉํ๋ ์ด์ ๊ฐ ๋ฌด์์ธ๊ฐ์?
๋ต๋ณ๊ฐ์ฌํฉ๋๋ค ๊ทธ๋ฐ๋ฐ ๊ทธ ๋์ ์ฐจ์ด๋ฅผ ๋ณด๋ค๋, xml์ ์ฌ์ฉํ๋ฉด ์ข์ ์ด์ (์ฅ์ )๊ฐ ์๊ณ ์ถ์ด์
- 0
- 2
- 448
Q&A
๋ ์ด์์ ๋ฏธ๋ฆฌ๋ณด๊ธฐ์ ๋ํด์
์๋ฌธ์๋ต ๋ค์ ํ๋ฒ ํ๋ฉด์์ ์ด๊ฒ์ ๊ฒ ์ฐพ์๋ณด๋ค ์ฐพ์์ต๋๋ค! (์ฌ์ง)
- 0
- 1
- 629
Q&A
ObservableSequenceEqualExample.java ์์ ์ delay( ) ์ฐ์ฐ์ ์ง๋ฌธ์์ต๋๋ค
๋ค๋ฅธ ์๊ฐ์๋ค์ด ์ฐธ๊ณ ํ๋ฉด ์ข์ ๊ฒ ๊ฐ์ ๋๊ธ ์ถ๊ฐํฉ๋๋ค ์์ ObservableDelayExample02.java์ ๋ก๊ทธ๋ฅผ ์ถ๋ ฅ์์ผ ํ์ธํด๋ณด์๋๋ฐ์, ์ฒซ ๋ฒ์งธ ์ ํ์ delay( ) ์ฐ์ฐ์๋ง computation ์ค๋ ๋์์ ์คํ๋๋ ๊ฒ ๊ฐ์ต๋๋ค - Code & Result public class ObservableDelayExample02 { public static void main(String[] args) { Observable.just(1,3,5,7) .delay(item -> { TimeUtil.sleep(1000L); Logger.log(LogType.DO_ON_NEXT, item); return Observable.just(item); // ์๋ก์ด Observable์ ํต์ง ์์ ์, ์๋ณธ ๋ฐ์ดํฐ๋ฅผ ํต์งํ๋ค. }).subscribe(data -> Logger.log(LogType.ON_NEXT, data)); }} doOnNext() | main | 20:20:38.076 | 1 onNext() | main | 20:20:38.148 | 1 doOnNext() | main | 20:20:39.148 | 3 onNext() | main | 20:20:39.148 | 3 doOnNext() | main | 20:20:40.159 | 5 onNext() | main | 20:20:40.159 | 5 doOnNext() | main | 20:20:41.160 | 7 onNext() | main | 20:20:41.160 | 7 ์ด๋ฆ์ ๊ฐ์ ์ฐ์ฐ์์ธ๋ฐ ์ ์ด๋ ๊ฒ ๋ด๋ถ๋์์ด ๋ค๋ฅธ๊ฑธ๊น์? ์ฌ๋ ํท๊ฐ๋ฆฌ๊ฒใ ใ
- 0
- 3
- 283
Q&A
Schedulers.computation()์ ๊ดํ์ฌ
๊ฑด์์ฌํญ์ด ์๋๋ฐ์, ๊ฐ์ ํ๋ฉด์ ์ฌ์ด๋ ๋ฉ๋ด์ ์ปค๋ฎค๋ํฐ์ ์ฌ๋ฆฐ ์ค ๊ฒ์๊ธ(=์ฒซ ๋ฒ์งธ ๋๊ธ?)๋ง ๋ณด์ฌ์ง๊ณ , ๋๋๊ธ์ ๊ฐ์ ํ๋ฉด์์ ๋ณด์ด์ง ์์ ๊ฒ์ ๋ฐ๊ฒฌํ์ต๋๋ค. (์ฌ์ง) ์ธํ๋ฐ ์ฒซ ๋ฒ์งธ ๋๊ธ๊ณผ ๋๋๊ธ ๊ธฐ๋ฅ์ด ์ด๋ ํ๋ฉด์ด๋์ ๋ฐ๋ผ ์ผ๋ถ ๋ถ๋ฆฌ๊ฐ ๋์ด์๋ ๊ฒ ๊ฐ์ต๋๋ค. ๊ฐ์ฌ๋๊ป์ ๋ต๊ธ์ ์์ฑํด์ฃผ์ค ๋ ๋๋๊ธ์ด ์๋ ๊ทธ๋ฅ ๋๊ธ๋ก ์์ฑํด ์ฃผ์๋ฉด ๋ค๋ฅธ ์๊ฐ์๋ค์ด ์ง๋ฌธ์ ์ฐธ๊ณ ํ ๋ ์ข์ ๊ฒ ๊ฐ์ต๋๋ค!
- 0
- 5
- 435
Q&A
Schedulers.computation()์ ๊ดํ์ฌ
์ถ๊ฐ ์ง๋ฌธ ์์ต๋๋ค ๋ต๋ณํด ์ฃผ์ ๋ด์ฉ ์ค 'observeOn( )์ ๊ฒฝ์ฐ์๋ ... ์์ฐ์ ์ชฝ์์ ํต์งํ ๋ฐ์ดํฐ๋ฅผ ๊ฐ๊ณตํ๋ ๊ทธ ์์ ์ ์ฐ๋ ๋๋ฅผ ๋ณ๊ฒฝํ๋ ๊ฒ์ด๊ธฐ ๋๋ฌธ์ Future๊ฐ ๊ฒฐ๊ณผ๊ฐ์ ๋์ ธ์ฃผ๊ธฐ ์ํ ์ฐ๋ ๋์ ์ํฅ์ ์ฃผ์ง ์๊ธฐ ๋๋ฌธ์ด๋ผ๊ณ ์๊ฐ๋ฉ๋๋ค.' ๋ผ๊ณ ํด์ฃผ์ จ์ต๋๋ค. ์ ๊ฐ ๋ณต์ตํ๋ฉด์ ์ด๊ฒ๊ณผ ๊ด๋ จํด์ ์ธํฐ๋ท์์ ์ฐพ์ ์ด๋ฏธ์ง๊ฐ ์๋๋ฐ์, (์ฌ์ง) ์ ์ด๋ฏธ์ง๋ subscribeOn( )๊ณผ observerOn( ) ๋ฉ์๋๋ฅผ ์ฝ๊ฒ ์ดํด์ํค๊ฒ ๋ ํํํ ๋ง๋ธ ๋ค์ด์ด๊ทธ๋จ์ผ๋ก ๋ณด์ด๋๋ฐ, ํด๋น ์ด๋ฏธ์ง๋ ๋ง์ํด์ฃผ์ ๋ต๋ณ๊ณผ ๋์กฐํด๋ณผ ๋ ๋ค๋ฅธ ์ ์ด ์๋ ๊ฒ ๊ฐ์ต๋๋ค. ์ ์ด๋ฏธ์ง์์ observeOn(โถ) ์ฐ์ฐ์๋ง ์ดํด๋ณด๋ฉด, observeOn(โถ) ์ฐ์ฐ์๊ฐ ํธ์ถ๋ ์์ ๋ถํฐ โถ์ค๋ ๋๋ก ๋ณ๊ฒฝ๋ ๊ฒ์ผ๋ก ํํ๋์ด ์์ต๋๋ค. ๊ทธ์ ๋ฐ๋ฉด, ๋ต๋ณํด์ฃผ์ ๋ด์ฉ์ ๋ง์ถฐ ์ ๊ทธ๋ฆผ์ ๋ด์ฉ์ ์์ ํ์๋ฉด, observeOn(โถ) ์ดํ๋ถํฐ ์ค๋ ๋ โถ์ผ๋ก ๋ณ๊ฒฝ๋๋ ๊ฒ์ด ์๋, ์๋ map({โ-->โก}) ์ฐ์ฐ์๋ฅผ ํตํด ํต์ง๋ ๋ฐ์ดํฐ๋ฅผ ๊ฐ๊ณตํ๋ ์์ ์ด ๋์ด์ผ ํ๊ธฐ ๋๋ฌธ์ observeOn(โถ)์ map({โ-->โก}) ์ฌ์ด์ ๊ณผ์ ์ โถ์ค๋ ๋์์ ์คํํ๋ ๊ฒ์ผ๋ก ๋ํ๋ด์ผ ํ ํ ๋ฐ ์ด๋ ๊ฒ์ด ์ณ์ ๊ฒ์ผ๊น์?
- 0
- 5
- 435
Q&A
Reactive Streams์ ๊ตฌ์ฑ์์๋ค๊ณผ RxJava์ ๊ตฌ์ฑ์์๋ค์ ๊ด๊ณ?
๋ต๋ณ ๊ฐ์ฌํฉ๋๋ค! ๋ค์ ๊ณต๋ถํด๋ ์๋ก ๊ณต๋ถํ๋ ๋๋์ด ๋๋๊ฑด ์์ผ๊น์ใ
- 1
- 2
- 362
Q&A
ObservableSequenceEqualExample.java ์์ ์ delay( ) ์ฐ์ฐ์ ์ง๋ฌธ์์ต๋๋ค
์ด์ ์ผ ์ดํดํ์ต๋๋ค ๋ต๋ณ ๊ฐ์ฌํฉ๋๋ค! ์ด๊ฑด ๋ค๋ฅธ ์ง๋ฌธ์ธ๋ฐ์, Reactor์ ๋ํด์ ๊ด๋ จ ๊ฐ์๊ฐ ๋์ค๊ธฐ ์ ์ ๋ฏธ๋ฆฌ ๊ณต๋ถ๋ฅผ ํด๋ณด๋ ค๊ณ ํฉ๋๋ค. ํน์ ์ถ์ฒํ ๋งํ ์์ ์ด๋ ๊ด๋ จ ์๋ฃ๊ฐ ์์๊น์??
- 0
- 3
- 283
Q&A
Schedulers.computation()์ ๊ดํ์ฌ
๊ฐ์ฌํฉ๋๋ค! ๊ฐ์๋ฅผ ๋ชจ๋ ์๊ฐ์ ํ์ง๋ง ๋ณต์ต์ ํ์์ฑ์ ์ ์คํ ๋๋๋๋ค.. ๊ฐ ๊ธธ์ด ๋๋ฌด ๋ฉ๊ฒ ๋๊ปด์ง๋๋คใ
- 0
- 5
- 435
Q&A
์กฐ๊ธ ๋ ์์ธํ ์ค๋ช ๋ถํ๋๋ฆฝ๋๋ค
๋ต๋ณ ๊ฐ์ฌํฉ๋๋ค! ์ ๊ฐ test๊ฐ ์๋ ํ๊ฒฝ์์ ํด๋น ์์ ๋ฅผ ๊ฐ์ง๊ณ assertThat( ) ๋ฉ์๋๋ฅผ ์ ์ธํ๊ณ ์คํ์์ผ ๋ณด์๋ subscribe( ) ๋ฉ์๋์ ๊ฒฐ๊ณผ๊ฐ ๋์ค์ง ์๋๋ผ๊ตฌ์ ์ด๊ฒ๋ RxComputationThreadPool๋ก๋ถํฐ์ ๋ฐ์ดํฐ๋ฅผ ํต์ง๋ ํ๊ธฐ ์ ์ main ์ค๋ ๋์์์ ์์ ์ด ๋๋์ ๊ฒฐ๊ณผ ๊ฐ์ด ์๋์จ ๊ฒ์ด๊ตฐ์? ListCarMaker> carMakerList = new ArrayList(); SampleObservable.getCarMakerStream() .map(data -> carMakerList.add(data)) .subscribe(data -> Logger.log(LogType.ON_NEXT, carMakerList));// TimeUtil.sleep(1000L); - ์ค๋ ๋ ์ง์ฐ ์๊ฐ ์ ์ฉ ์ ๊ฒฐ๊ณผ onNext() | RxComputationThreadPool-1 | 22:51:26.875 | [CHEVROLET] onNext() | RxComputationThreadPool-1 | 22:51:26.877 | [CHEVROLET, HYUNDAE] onNext() | RxComputationThreadPool-1 | 22:51:26.877 | [CHEVROLET, HYUNDAE, SAMSUNG] onNext() | RxComputationThreadPool-1 | 22:51:26.878 | [CHEVROLET, HYUNDAE, SAMSUNG, SSANGYOUNG] onNext() | RxComputationThreadPool-1 | 22:51:26.878 | [CHEVROLET, HYUNDAE, SAMSUNG, SSANGYOUNG, KIA]
- 0
- 2
- 291
Q&A
defer( ), fromFuture( )๋ just( )์ฒ๋ผ ์ฌ๋ฌ ์ธ์ ๊ฐ์ ๋ฐ์ ์ ์๋์ง ๊ถ๊ธํฉ๋๋ค.
์ฒ์ฒํ ๋ต๋ณํด ์ฃผ์ ๋ ๋๋๋ฐ ๋นจ๋ฆฌ ๋ต๋ณ์ ์ฃผ์ ์ ๊ฐ์ฌํฉ๋๋คใ ใ ๊ฐ์ฌ๋์ ๊ฐ์๋ฅผ ์์์ผ๋ก ๋ฆฌ์กํฐ๋ธ ํ๋ก๊ทธ๋๋ฐ์ ์ฌ๋ฏธ๊ฐ ๋ถ์ด ์ด๊ฒ์ ๊ฒ ๋ค๋ค๋ณด๋ค ๋ณด๋ ๊ถ๊ธํ ์ ์ด ๋ง์์ง๋ค์ ๊ทธ๋ผ์๋ ๋ถ๊ตฌํ๊ณ ์น์ ํ๊ฒ ๋ต๋ณํด ์ฃผ์ ์ ๊ฐ์ฌํฉ๋๋ค! p.s. ์ถํ์ ๊ฐ์คํ์ค ๊ฐ์๋ ๋๋ฌด ๊ธฐ๋๋ฉ๋๋ค! ๋นจ๋ฆฌ ๋์์ผ๋ฉดใ ์ธ์ ์ฏค ๊ฐ์ค๋๋์..?p.s. 2 ํน์ ์ด๋ฉ์ผ ์ฃผ์๋ฅผ ์๋ ค๋๋ ค์ผ ํ ๊น์?
- 0
- 3
- 245




