akka-stream

3열

1답변

여러 수신 TCP 연결을 Akka 스트림의 스트림으로 나타내는 방법은 무엇입니까?

Akka Streams를 사용하여 포트에서 수신 대기하고 들어오는 연결을 수락하며 각 연결에서 데이터를 지속적으로 읽는 네트워크 서버를 프로토 타이핑하고 있습니다. 연결된 각 클라이언트는 데이터 만 보내고 서버에서 유용한 정보를 얻지는 않을 것입니다. 개념적으로, 들어오는 이벤트를 실수로 여러 TCP 연결을 통해 전달되는 하나의 단일 스트림으로 모델링하는

3열

2답변

Akka 리 액티브 스트림은 항상 하나의 메시지 뒤에 있습니다

어떤 이유로, 제 Akka 스트림은 항상 첫 번째 메시지를 "방출"(?)하기 전에 두 번째 메시지를 기다립니다. 다음은 내 문제를 보여주는 몇 가지 예제 코드입니다. val rx = Source((1 to 100).toStream.map { t => Thread.sleep(1000) println(s"doing $t") t })

10열

1답변

상태에서 Akka 스트림을 중지하는 올바른 방법

나는 파일의 내용을 스트리밍하고 각 줄에 대한 변환을 계산하고 결과를 집계/축소하는 데 성공적으로 FileIO을 사용했습니다. 이제 조건에 도달하면 스트림을 중지하고 전체 파일을 읽을 필요는 없지만 프로세스가 가능한 빨리 끝납니다. 이것을 달성하기 위해 권장되는 방법은 무엇입니까?

0열

1답변

PlayWS - Materializer null

을 사용하여 Java로 WSClient 만들기 기본적으로 Java를 사용하여 내 SBT 응용 프로그램에서 사용자 지정 WSClient를 만들려고합니다. 왜냐하면 나는 어떤 주사 의존성도 원하지 않기 때문에 나는 documentation에 나와있는 방법을 사용하고있다. 커스텀 WSClient를 생성하기 위해서는 Akka.stream.Materializer 오

0열

2답변

텍스트 파일에서 Akka 소스 [문자열]을 어떻게 만듭니 까?

이것은 세계에서 가장 단순한 것 같지만 시작하기 만하면 나는 곤란합니다. 그러니 나와 함께 견뎌주십시오. FileIO 목적은 당연히 Source[ByteString, Future[IOResult]] 반환 fromFile 기능을 제공한다. 하지만 UTF로 인코딩 된 텍스트 파일이 있는데이 파일은 Source[String, Future[IOResult]]입니다

6열

3답변

두 개의 Akka 스트림 소스로 나누기

나는 Accka Streams Source을 가지고 있는데, 술어에 따라 두 개의 소스로 나누고 싶습니다. 예. 소스는 (타입 의도적 간략화)을 갖는 : val source: Source[Either[Throwable, String], NotUsed] = ??? 두 방법 : 싶습니다 def handleSuccess(source: Source[String

2열

1답변

Akka 스트림 -지도에 나열된 개별 요소의 동기화

내 스트림의 출력에 List [Any] 객체가있는 Flow가 있습니다. 나는 mapAsync를 가지기를 원했고 각각의 다른 단계는리스트 대신 개별 요소를 처리했다. 어떻게해야합니까? 나는이 작업을 수행하려면 어떻게 Flow[Any].mapAsyncUnordered(4) { listElement => actorRef ? listElement }.s

1열

2답변

Akka Stream - CRON과 같은 타이머 또는 스케줄러

저는 Akka Stream on Scala를 사용합니다. 24:00에 실행되는 스케줄러를 설정하고 싶습니다. 나는 그것을 찾으려고 노력했다. 그러나 나는 내가하고 싶은 것을 찾지 못했습니다. 코드 작성 방법을 알려주시겠습니까?

0열

1답변

elastic4s 가입자의 응답을 akka-stream으로 되 돌린다

현재 mongoDb에서 elasticsearch로 데이터를 스트리밍하는 솔루션을 구축 중입니다. 내 목표는 elasticsearch에 성공한 모든 전송 항목을 추적하는 것입니다. akka-streams 및 elastic4s를 사용하고 있습니다. 현재 ES로 스트리밍이 val esSubscriber: BulkIndexingSubscriber[CustomT]

3열

1답변

Akka-streams - flatMapConcatenated 인 소스의 구체화 된 값을 다른 소스로 가져 오는 방법?

Future [Source [Out, Mat]]에서 Source [Out, Mat]를 생성하려고 시도하고 있으며 flatMapConcat과 함께 기본 제공 source.fromFuture를 사용하고있었습니다. 그러나 fromFuture를 사용할 때 원본은 NotUsed의 구체화 된 값을가집니다. 실제 소스를 flatMapConcatenating 할 때 구체