akka-stream

2열

1답변

webSocketClientFlow에있는 doc에 따라 클라이언트 측 websocket을 시도하고 있습니다. 샘플 코드는 다음과 같습니다 연결이 업그레이드했다 import akka.actor.ActorSystem import akka.Done import akka.http.scaladsl.Http import akka.stream.ActorMateri

0열

2답변

없음 출력하지 나는 다음과 같은 파일을 줄을 읽어 Akka 파일 입출력을 사용하고 파일

읽기 : def main(args: Array[String]): Unit = { implicit val system = ActorSystem("MySys") implicit val materializer = ActorMaterializer() FileIO.fromPath(Paths.get("/foo/1.csv")).via(Fram

6열

1답변

Akka 스트림 형

에 의해 스트림을 분할 나는 다음과 같은 간단한 경우 클래스 계층이 있습니다 sealed trait Message case class Foo(bar: Int) extends Message case class Baz(qux: String) extends Message 을 그리고 나는 Flow[Message, Message, NotUsed] (코덱과 웹

0열

1답변

해결 방법 - 개체 WebSocket을 사용하는 메서드가 더 이상 사용되지 않습니다. 대신에 Akka 스트림 흐름을 사용하여 accept를 사용하십시오.

재생 2.4에서 2.5로 내 응용 프로그램을 마이그레이션하려고합니다. 마이그레이션하는 동안 사용되지 않는 기능을 제거하려고합니다. 내가받는 경고 중 하나가 입니다. 객체 WebSocket에서 사용하는 메소드가 더 이상 사용되지 않습니다. 대신에 Akka 스트림 흐름에서 accept를 사용하십시오. 다음은이 코드를 리팩터링하는 방법입니다. 아카 스트림이 흐른

0열

2답변

노드 크래시 발생시 akka 액터에서 대기중인 메시지를 복구하는 방법은 무엇입니까?

노드가 충돌하고 그 시점에 메시지가 사서함에 대기열에 있으면 노드가 메시지를 다시 처리 할 수 있습니까? 다시 처리 할 수없는 경우 akka 프로그래밍 모델에 내결함성이 있다고 말할 수 있습니다. 이것은 현재 영구 큐를 사용해야하는 가장 기본적인 사용 사례입니다.

2열

2답변

Akka Streams - 일부 술어를 기반으로 들어오는 소스 데이터를 분할합니다.

저는 Akka Streams 프레임 워크의 초보자이며 Akka Stream의 목표에 대한 문제를 해결할 수있는 가능성을 알고 싶습니다. 여기에 문제가 있다고 상상해보십시오. 몇 가지 큰 iteratee 소스가 있습니다. 아마도 큰 데이터를 가진 3-4 큰 파일 같은 데이터; 각 파일을 처리해야합니다. 구문 분석, 변환 된 평균값 계산; 파일의 데이터는 일부

3열

1답변

Source.fromIterator가 Iterator [T] 대신 Function0 [Iterator [T]]를 매개 변수로 사용해야하는 이유는 무엇입니까? 을 바탕으로

: Source.fromIterator의 매개 변수가 Function0[Iterator[T]] 대신 Iterator[T] 이유 source code 내가하지 않습니다. 전제 사유가 있습니까? 대신 서명을 def fromIterator(iterator: => Iterator[T]) (으)로 변경할 수 있습니까? the docs으로 당

2열

1답변

akka-streams 맵에서 비동기 드라이버를 사용하는 방법 mapAsync

방금 reactivecouchbase 비동기 데이터베이스 드라이버를 사용하기 시작했지만 기본적인 디자인 문제가 발생합니다. 전통적인 접근 방법에서는 연결 수를 제한하여 데이터베이스에 가하는 압력을 제한합니다. 그러나 비동기 드라이버를 사용하면 데이터베이스를 새로운 쿼리로 늪에 잠길 수 있습니까? 이것은 중요한 예가 다음과 같습니다. 두 가지 다른 방법으

5열

2답변

Akka HTTP Websocket, 액터 내부의 연결을 식별하는 방법

JS 클라이언트 용 웹 소켓을 통해 공개하고 싶은 간단한 멀티 플레이 게임을 스칼라로 작업 중입니다. 여기에이 웹 소켓 서버에서 메시지를 수신해야 내 배우의 코드를 단순화 class WebsocketServer(actorRef: ActorRef, protocol: Protocol, system: ActorSystem, materializer: ActorMa

1열

1답변

Play framework, Akka Persistence, PersistenceQuery, Action.async의 Future Object로 소스를 변환 할 수 없습니다.

지속적인 이벤트 목록을 가져 와서 응답 (Action.async)으로 보내려고합니다. 그러나 PersistenceQuery 개의 결과를 Future 개체로 변환 할 수 없습니다. 여기에 내가 runFold 내에서 인쇄물을 볼 수 있어요 코드 val queries = PersistenceQuery(actorSystem).readJournalFor[Cassan