akka-stream

-1열

1답변

이의 내가 소스가 있다고 가정하자 : val source = Source(List(1,2,3)) 어떻게 할 수 있습니까 메시지 배우 같은 소스? sourceActor ! 4

0열

1답변

Akka의 EventStream에서 서버 측 이벤트를 어떻게 만들 수 있습니까?

I 시도 : EventStream -> 소스 -> Akka HTTP (SSE) 내가 그것을보고,이 소스가 Akka의 HTTP complete(Source, ...) 에 의해 구체화되기 때문에, 작동하지 않을 수 있고, 구체화에 EventStream에서 메시지를 보낼 수 소스 나 (ActorRef 것을 얻을 수있는 방법이 있나요?)을 ActorRef 필요 내

0열

1답변

맵 (T => Future [U])과 flatMapConcat (T => Source.fromFuture (Future [U])) 사이의 Akka 스트림 차이

싱크를 정의하는 두 가지 방법의 차이점은 무엇인가요? [RandomCdr, Future 하는 Future에 Flow[RandomCdr] .grouped(bulkSize) .flatMapConcat{ (bulk : Seq[RandomCdr]) => Source.fromFuture(collection.flatMap(_.inser

0열

1답변

Akka SourceQueue가 목록 요소를 보내려면

나는 List[String]과 Source.queue을 가지고 있습니다. 나는이 대기열 문자열 요소를 일정 시간 간격 후에 제공하려고합니다. 다음과 같이 입력하십시오 : val data : List[String] = "" val tick = Source.tick(0 second, 1 second, "tick") tick.runForeach(t => qu

0열

1답변

Akka 스트림 - 전체 목록

내가 요소의 목록을 소비하고 요소의 전체 목록은 다음 목록의 크기를 전달하고자하는 다음 목록의 크기를 생성하는 방법. 예. Given List (1, 2, 3, 4, 5) When the source is fully consumed Then the next processing-stage receives the elements List(5, 1, 2, 3

1열

1답변

Akka Stream - Pausable GraphStage (Akka 2.5.7)

다른 액터에서 메시지를 보내 일시 중지/일시 중지 해제 할 수있는 GraphStage를 작성하고 싶습니다. 아래 코드는 임의 번호를 생성하는 간단한 GraphStage을 보여줍니다. 무대가 구체화되면 GraphStageLogic은 StageActor이 포함 된 메시지 (preStart())를 감독자에게 보냅니다. 감독자는 무대의 ActorRef을 유지하므로

0열

2답변

왜이 akka-http 경로 테스트가 성공적으로 완료되지 않습니까?

나는 단순한 경로를 가졌지 만 일부는 개별적으로 성공을 테스트했지만 시간 초과로는 전체적으로 실패합니다. 왜 그런가? val route = (requestHandler: ActorRef @@ Web) => { get { pathPrefix("apps") { pathEndOrSingleSlash { completeWit

0열

1답변

일부 초기 표시로 대기열 제공

일부 초기 지연 후 10 초라고 말하면로드 요청에서 전송 된 문자열을 대기열에 넣으 려합니다. 짧은 간격 지연 (1 초)으로 다음 요청을하면 모든 것이 정상적으로 작동하지만 스크립트 에서처럼 계속 실행하면 지연이 없습니다. 다음은 샘플 코드입니다. def load(randomStr :String) = Action { implicit request =>

0열

1답변

카프카에 대한 질문 여러 노드의 Akka-Streams를 통한 과도 메시지 소비자

우리는 카프카를 사용하여 클러스터에있는 노드에 의해 생성 된 메시지를 클러스터의 모든 노드에 저장하고 있습니다. akka-streams 그러나 이것을 묶어야하는 몇 가지 질문이 있습니다. 이것에는 몇 가지 제약이 있습니다. 우선 메시지는 클러스터의 모든 노드에서 소비되어야하지만 하나의 노드 만 생성해야합니다. 나는 각 노드에 아마도 노드 ID 인 그룹 ID

0열

1답변

Alpakka JMS 거래

나는 Oracle AQ에서 데이터를 대기열에서 제외하기 위해 Alpakka 및 그 JMS 커넥터로 게임을하고 있습니다. 아래의 매우 기본적인 구현 방법을 따라 가면 this 가이드가 될 수 있습니다. 제 질문은 어떻게 처리 할 수 있습니까? 예외가 발생하면 내 메시지가 손실되지 않도록 보장 할 수 있습니다. 이 PL/SQL 인 경우 object Cons