저는 Java에서 ReactiveX 확장으로 2 년 동안 일해 왔지만 지금은 scala로 옮겼습니다. 많은 사람들이 ScalaZ 확장을 사용하여 Scala에서보다 기능적인 프로그래밍을 수행하는 것을 보았습니다. ScalaZ 확장을 사용하는 데 차이가 있습니까? 아니면 내가 수행 한 스칼라에 reactiveX를 적용하고 스칼라로 멋지게 움직이는 지 알고 있습
웹 사이트의로드 생성기 인 시스템을 모델링하려고합니다. 이 웹 사이트에는 지금은 문자열 인 페이지가 있습니다. type Page = String
val pages: Vector[Page] = Stream.eval(Task.delay {
new Random().alphanumeric.take(10).mkString
}).repeat.take(1
http4s 라이브러리를 사용하여 멀티 파트 콘텐츠를 처리하는 방법을 알고 싶습니다. Multipart Data
Parts:2
Some(birthDate), headers: Content-Disposition: form-data; name="birthDate"
Some(dataFile), headers: Content-Disposition: form-
일부 요청을 실행 한 후 비동기 http4s 클라이언트에서 결과 모음을 얻습니다. 이 컬렉션 (Seq[Task[Response]])이 모든 Task 개체에 대해 완료되었으며 Response 개체가 특정 상태에 있는지 확인하고 싶습니다. 내가 대신 작업의 Future을 사용한 경우, 내가 대신 fs2.Task를 사용하여 유사한 기능을 달성 할 수있는 방법이
FS2에 Object Pool pattern을 구현하는 가장 좋은 방법을 찾으려고합니다. class MyPrinter {
import scala.util.Random.nextInt
Thread.sleep(5000 + nextInt(1000))
def doStuff(s: String): Unit = {
println(s)
나는 Stream[F,A]을 가지고 있으며, fs2을 인식하지 못하는 코드베이스의 일부분에 의해 소비되기 위해서 다음의 "원시 스트리밍 인터페이스"로 변환해야합니다 : trait PrimitiveStreamRepr[F[_]] {
def read: F[Option[A]]
def close: F[Unit]
}
어떻게하면됩니까? 아마도 대
, 나는 스칼라 컬렉션 '스트림을 사용하여 nifty recursive implementation을 가로 질러 와서 FS2에 시도에서 나는 이동을 거라고 생각 :이 import fs2.{Pure, Stream}
val fibs: Stream[Pure, Int] = Stream[Pure, Int](0) ++ fibs.fold[Int](1)(_ + _
외부 병합 정렬을 스칼라로 구현하고 싶습니다. 주 메모리 전체에 들어갈 수없는 거대한 파일을 정렬하는 데 사용됩니다. 자세한 내용은 여기에서 찾을 수 있습니다 : - How external merge sort algorithm works? 지금, 나는 파일의 청크를 읽을 필요가 정렬이 디스크에 기록하고 등 등 독서의 가장 관용적/기능성 방법을 무엇 /거대한