inflearn logo
강의

강의

N
챌린지

챌린지

멘토링

멘토링

N
클립

클립

로드맵

로드맵

지식공유

Kevin의 알기 쉬운 RxJava 1부

리액티브 연산자 개요 및 생성 연산자

CarRepairShop에 대한 예제 코드를 볼 수 있을까요?

183

parkht

작성한 질문수 20

0

안녕하세요.

먼저 RxJava에 개념을 잡는데 좋은 강의를 해주셔서 감사합니다. 많은 도움이 되고 있습니다.

혹시 CarRepairShop에서 Future를 리턴하는 getCarRepairCostAsync 메서드에 코드를 확인할 수 있을까요?

Future를 사용해본적이 없어서요...ㅠ

확인 부탁드립니다.

함수형-프로그래밍 Reactive-Streams Reactive Programming RxJava

답변 1

0

Kevin

안녕하세요? 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