Akka 스트림 응용 프로그램에서 응용 프로그램이 충돌하거나 노드가 다운되면 기내 메시지가 손실 될 위험이 있습니다. 우리가 메시지를 잃지 않도록하기 위해 할 수있는 일은 응용 프로그램이 돌아 오면 수행됩니다. 내 응용 프로그램에서 mapAsyns IO 호출 및 일부 사소한 CPU 바운드 작업을 수행합니다. 순수한 Akka 응용 프로그램에서 영구 대기열 또
내가 외부 API를 호출하고 내가 OK과 다른 상태 코드의 경우 사용자에게 "있는 그대로"결과를 반환하려는 실패한 경우 보내는 응답 응답 : val connectionFlow: Flow[HttpRequest, HttpResponse, Future[Http.OutgoingConnection]] =
Http().outgoingConnection("ak
기본적으로 사용자가 서버에서 CSV 파일을 다운로드 할 수있게하려고합니다. CSV 파일이 이미 서버에 있다고 가정합니다. API 엔드 포인트는 GET/export를 통해 공개됩니다. Akka HTTP 서버에서 클라이언트로 파일을 스트리밍하려면 어떻게해야합니까? 이 ... 나는 지금까지 무엇을 가지고 서비스 : def export(): Future[IORes
documentation to implement a KillSwitch에 따라 프레임을 내보내는 사용자 지정 SourceShape의 킬 스위치이 간단한 예제를 작성하여 무한 수를 방출하는 소스를 중지 할 수있었습니다. object KillSwitchSample extends App {
implicit val actorSystem = ActorSys
더 나은 방법 다음과 같은 방법을 구현할 수 있는가 (즉, Materializer 제약 조건을 제거하여.) : import akka.NotUsed
import akka.stream.Materializer
import akka.stream.scaladsl.{Keep, Sink, Source}
def assemble[A, B, C](source: Sou
akka-stream 흐름을 쉽게 재사용 할 수있는 방법을 찾고 있습니다. 가 나는 함수로 재사용하려는 흐름을 취급, 그래서 내가 좋아하는 그 서명을 유지하고 싶습니다 :이 흐름을 사용하면 이제 수 있도록하고 싶습니다 Flow[Input, Output, NotUsed] '호출 '이 흐름과 추가 처리를 위해 결과를 따로 보관하십시오. 그래서 Flow로 시작하
내 프로젝트에서 내 fcm 서버에 게시물 요청을 보내는 akka 배우가 있습니다. 액터는 ID 목록을 가져와 목록에있는만큼 많은 요청을 만들어야합니다. runForeach(println(_))에있는 서버의 응답을 인쇄하지만 전체 ID 목록에 대해 하나의 출력물 만 얻습니다. 왜 이런 일이 생길까요? class FCMActor(val key: String)
akka-streams에서 "aggregator"블록을 찾고 있습니다. 예를 들어, 블록이 3 개의 문자열을 수신 할 때까지 기다린 다음 평균 길이를 계산하는 것과 같은 동작을 트리거하고 동작 결과를 다운 스트림에 전파합니다. 흐름은 세 개의 문자열을받을 수 기다릴 것 "hallo"
"boat"
"cat"
후 평균 길이 4
을 평가하고 다운 스트