자바에서 코틀린으로

260

자바에서 코틀린으로

에 스트림이 스루풋

throughput

을 위해서는 좋은 선택인 것처럼 보인다. 그렇다면 왜 스트림을 코

틀린으로 변환해야 할까? 하지만 이런 태도를 바라고 이 책을 구입하지는 않았을 것이다. 따라

서 리팩터링의 매 단계마다 성능을 측정하는 것으로 가정하면서 성능이 크게 저하되는 경우에

만 리팩터링을 멈출 것이다.

13.7.1

이터러블을 먼저 고려하기

코드를 살펴보면 두 가지 단계를 볼 수 있다. 첫 단계는 길이가 정해지지 않은 입력을 처리해서

메모리상에 컬렉션을 만든다.

예제

13.5

[

streams

-

to

-

sequences

.

2

:

src

/

main

/

java

/

travelator

/

analytics

/

MarketingAnalytics

.

kt

]

val eventsForSuccessfulBookings = eventStore

.queryAsStream(“type=CompletedBooking&timerange=$timeRange”)

.flatMap { event ->

val interactionId = event[“interactionId”] as String

eventStore.queryAsStream(“interactionId=$interactionId”)

}

val bookingEventsByInteractionId = eventsForSuccessfulBookings.collect( ...