빠르고 정확한 개발자 빠르고 정확한 개발자

scala future

• java callback 을 scala Future 로 바꾸기

  scala/basic 2022. 7. 16. 18:57

  문제 다음과 같이 java Async Http Client 의 callback 을 scala Future 로 변경해 코딩해 보자 val asyncHttpClient = org.asynchttpclient.Dsl.asyncHttpClient() val listenableFuture = asyncHttpClient.prepareGet("https://api.agify.io/?name=meelad").execute() val listener = new Runnable { override def run(): Unit = { val body: String = listenableFuture.get().getResponseBody(scala.io.Codec.UTF8.charSet) println(body) } } l..

  Read More
• Task 타입을 Future 로 변환해 자연스럽게 사용하기

  zio/zio1 2021. 7. 23. 17:43

  다음 처럼 implicit class 를 정의해 사용하면, 비교적 자연스럽게 zio Task 를 scala Future 로 변환할 수 있다. implicit class ZioOps[T](task: Task[T]) { def runToFuture: Future[T] = Runtime.default.unsafeRunToFuture(task) }

  Read More
• Future 의 concurrency control

  scala/basic 2021. 3. 28. 15:52

  playframework 에서 1,000 개의 DB item 을 빠르게 조회할 필요가 있었다. play-ws 를 사용하면 Http Api 호출을 async action 으로 처리할 수 있다. 그런데 1,000 번의 Http Api 호출을 순식간에 진행해 DB 에 무리가 갈 수 있다. 오히려 성능을 제한해 한번에 100 건씩 호출해 10 번에 나누어서 처리하고 싶다. 아래 글을 참고해 코딩해 봤다. stackoverflow.com/questions/49924941/how-to-control-the-concurrency-of-future-sequence-in-scala How to control the concurrency of future.sequence in scala? I know that I can ..

  Read More