CarRepairShop에 대한 예제 코드를 볼 수 있을까요?
183
작성한 질문수 20
안녕하세요.
먼저 RxJava에 개념을 잡는데 좋은 강의를 해주셔서 감사합니다. 많은 도움이 되고 있습니다.
혹시 CarRepairShop에서 Future를 리턴하는 getCarRepairCostAsync 메서드에 코드를 확인할 수 있을까요?
Future를 사용해본적이 없어서요...ㅠ
확인 부탁드립니다.
답변 1
0
안녕하세요? CarRepairShop 클래스의 소스 코드는 아래와 같습니다.
public class CarRepairShop {
public int getCarRepairCostSync(int brokens) {
return calculateCarRepair(brokens);
}
public Future<Integer> getCarRepairCostAsync(int brokens) {
return CompletableFuture.supplyAsync(
() -> calculateCarRepair(brokens));
}
private int calculateCarRepair(int brokens){
Logger.log(LogType.PRINT,
"# 차량 수리비 계산 중................");
delay();
return brokens * 20000;
}
private void delay(){
try {
Thread.sleep(3000);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
여기서 getCarRepairCostAsync() 의 메서드 body 코드를 확인하실 수 있습니다. 보시다시피 java.util.concurrent 패키지내의 CompletableFuture 를 사용해서 Future를 반환하는것을 볼 수 있습니다.
충분한 답변이 되셨나 모르겠네요.
위 소스 코드는 제가 제공하는 github 소스 코드에서도 확인하실 수 있습니다.
감사합니다.
Single과 관련해 여쭤보고 싶은 부분이 있습니다!
0
270
2
cold/hot publisher 예제 코드와 관련해 질문 드립니다.
0
373
1
CompletableObserver 클래스의 람다식 표현관련
0
304
1
1강에 예시로 보여주신 ToDoSample 코드에 관해 질문 드립니다!
0
363
1
데이터 결합 연산자 / merge 관련 질문
0
457
1
DROP 배압 전략에 관한 궁금증
0
307
2
map에서의 TimeUtil.sleep에 관한 궁금점
0
221
1
강의 내용을 정리해서 개인 블로그에 올려도 될까요?
0
572
2
TimeUtil.sleep 관련 질문
0
293
1
배압 전략 중에서 DROP 전략과 관련해서 질문 있습니다.
0
340
1
Error 발생 시에도 계속 처리 방법
0
694
2
선언형 프로그래밍과 명령형 프로그래밍
1
793
2
첫번째 강의 부터 이번강의까지 수강하면서 궁금한점 질문드립니다.
0
331
1
안녕하세요. 질문이 있습니다.
1
358
1
logger 가 없는데 util 폴더도 같이 갖다놔야 하나요?
0
334
1
amb 연산자
0
241
1
질문 드립니다.
0
224
1
concatEager( ) 연산자에 관하여
0
321
1
Reactive Streams의 구성요소들과 RxJava의 구성요소들의 관계?
1
409
2
ObservableSequenceEqualExample.java 예제의 delay( ) 연산자 질문있습니다
0
320
3
defer( ), fromFuture( )도 just( )처럼 여러 인자 값을 받을 수 있는지 궁금합니다.
0
274
3
flatMapSingle() 메소드에 대하여
0
628
6
fromFuture() vs fromCallable() 생성 연산자에 대해
0
583
2
함수형 인터페이스 Comparator에 대해
0
404
2





