akka-stream

4열

1답변

akka http를 사용하여 포트에 바인드 한 다음 들어오는 연결을 라우팅하려면 documentation으로 충분합니다. 해결되지 않은 한 가지 질문은 다른 경로에 대해 여러 포트를 바인딩하는 방법입니다. 나는 여러 사양이있는 경우 : val route1 : Flow[HttpRequest, HttpResponse,_] = ??? val interface1

2열

1답변

Unmarshaller를 HttpRequest-> HttpResponse 흐름에 적용하려면 어떻게해야합니까?

HTTP 서비스를 사용하기 위해 Java 프로젝트에서 akka 프레임 워크를 사용합니다. 그 이유는 akka 스트림 작업에 javaDSL을 사용하기 때문입니다. 그래서 내 이야기는 아래에 있습니다. val pool = Http.get(getContext().system()).cachedHostConnectionPool( "https://someh

1열

1답변

내가이 재생 2.4 JSON 스트림 예 재생 2.4에서 2.5

내가 쓸 수 플레이 번역 할 수 있습니다 방법 : import play.api.libs.json._ import play.extras.iteratees._ val jsonStream: Enumerator[JsObject] = enumerator &> Encoding.decode() &> Enumeratee.grouped(

6열

1답변

스트림에서 Akka-http-client 요청을 연결합니다.

akka-http-client를 사용하여 HTTP 요청을 스트림으로 연결하고 싶습니다. 체인의 각 HTTP 요청은 이전 요청의 성공/응답에 따라 달라지며 새 요청을 생성하는 데 사용됩니다. 요청이 성공하지 못하면 스트림은 실패한 요청의 응답을 반환해야합니다. 어떻게 이러한 스트림을 akka-http로 만들 수 있습니까? akka-http 클라이언트 수준 A

0열

1답변

Akka Stream postStop에서 노드의 결과 상태를 쿼리

Akka Stream GraphStageLogicpostStop에서 스테이지가 오류없이 완료되었거나 완료되었는지 확인할 수있는 방법이 있습니까? 예 : Try[Unit]이면 failStage이 호출 된 경우 Failure, completeStage 인 경우 Success이됩니다. failStage는 final 방법이다, 그래서 documentation가 유

0열

1답변

Akka Stream : 파일 싱크에 쓸 수 없습니다.

간단한 Akka Stream File Sink 예제를 실행하려고하는데 성공하지 못했습니다. 소스를 만들고 Flow를 실행 한 다음 파일을 만들 수 있지만 ByteString이 파일에 기록되지 않습니다. 반면에 flow output을 콘솔에 출력하려고한다면 그렇게 할 수 있습니다. 내가 여기서 뭔가를 놓치고 있니? import akka.stream._ im

0열

1답변

WebSocket을 Play에서 Akka로 이동 HTTP

Play 앱에 WebSocket 서버가 있으며이를 akka-http 서비스로 이동하려고합니다. 저는 현재 Akka에 존재하지 않는 Play의 일부인 ActorFlow.actorRef을 사용하고 있습니다. WebSocket이 승인되면 RabbitMQ 대기열에 가입하고 각 메시지를 WebSocket으로 전달합니다. WebSocket에서 메시지를 받으면 일부는

1열

2답변

관용법으로 FileIO.fromPath에서 Bytestring을 얻는 방법

스칼라의 FileIO.fromPath에서 akka Bytestring을 가져 오는 관용적 인 방법은 무엇입니까? map FileIO.fromPath(Paths.get("some file path")).map { byteString => doSomething() }

0열

1답변

은 각각 HTTP가

내가 블로그 ID의 배치를 시작으로이 두 URI를 /posts/{id} : get a blog post by ID /comments?postId={id} : get all the comments on a blog by the blog's id 에 응답 편안한 블로그 서버 (http://jsonplaceholder.typicode.com)가 요청 만

5열

1답변

Future [T]를 방출하는 소스를 다루는 방법?

의 내가 어떤 반복자 있다고 가정 해 봅시다 : val nextElemIter: Iterator[Future[Int]] = Iterator.continually(...) 그리고 그 반복자에서 소스를 구축하려는 : val source: Source[Future[Int], NotUsed] = Source.fromIterator(() => nextE