conflate과 같은 Akka 스트림 기능을 테스트하고 싶습니다. 이를 위해 간단한 단위 테스트에서 배압의 영향을받지 않는 소스를 구성해야합니다. 순진한 시도는 기압으로 인해 작동하지 않습니다. Source.tick(1.milli, 1.milli, "tick").map(_ => Random.nextDouble())
HTTP를 거쳐가는 OTOH는 아마도
Play 2.5 애플리케이션에서 한 트랜잭션 내의 데이터베이스에서 많은 양의 데이터를 읽고 클라이언트에 HTTP 응답으로 전송하는 서비스를 만들어야합니다. 느린 네트워크 속도로 인해 데이터베이스에서 데이터를 가져 오는 데 사용 된 DB 연결이 너무 오래 사용 될 수 있으므로 역압을 사용하지 않으려합니다. 현재 구현은 먼저 데이터를 임시 버퍼 (너무 많은 데
파일의 시퀀스를 받아들이고, 실행이 끝날 때마다 하나씩 처리하는 그래프가 있습니다. 모든 실행이 성공 또는 실패하면 프로그램은 성공 (0) 또는 실패 (-1)를 반환해야합니다. 어떻게이 마지막 단계를 달성 할 수 있습니까? 싱크가 마지막 파일에 대한 결과를 수신하는 시점을 어떻게 알 수 있습니까? val graph = createGraph("path-to-
Im Akka 스트림에서 Source.combine을 사용하고 있습니다. 나는 모든 소스가 그래프 수명주기의 시작과 동시에 시작되어 source.combine 목록의 순서대로 일시 중지 및 다시 시작하기 전에 일부 입력을 버퍼링하는 것으로 나타났습니다. val singletonSources = builder.add(
Source.combine(
Akka 스트림에 싱크대로 끝나는 TCP 연결이 있습니다. 지금 모든 메시지는 하나의 싱크대에 들어갑니다. 몇 가지 기능이 주어진다면 스트림을 알 수없는 수의 싱크대로 분할하고 싶습니다. 사용 케이스는 지금은 그래서 지속적으로 축적 할 수있는 각 DeltaValue.id에 대한 actorSink를 작성하고 각 DeltaValue.id에 대한 동작을 구현하려
임 다음 코드가 작동하지 않으면 컴파일되지만 오류는 Expected OnNext(_), yet no element signaled during 3 seconds이됩니다. 왜 이런 오류가 발생하며 아래 흐름 유형 을 테스트하려면 어떻게해야합니까? class GeneralTests extends FunSuite {
implicit val system
저는 Akka Stream을 사용하여 스로틀을 구현하고 있으며 거의 효과가 있습니다. 매회마다 하나씩 메시지 목록을 보내려고하기 때문에 거의 효과가 있습니다. Akka의 액터가 호출 배우 이전에 메쉬를 축적 할 수 있는지 확실하지 않습니다. 다음 예제는 간단하지만 실제 시나리오에서 나는 RabbitMQ로부터 많은 메시지를 받게 될 것이고 너무 빠른 속도
나는 (다른 일치하지 않는 F 번호하지만 스칼라 버전으로 작성) Akka 스트림을위한 간단한 테스트 코드가 있습니다 var source = Source.From(Enumerable.Range(1, 3));
var flow = Flow.FromFunction(new Func<int, string>(x => (x * 2).ToString()));
CSV 파일을 가져 와서 XML로 변경하고 (toXml 함수가있는 기존 개체를 사용하여) 예제 akka 스트림을 작성하려고합니다. 이것을 엔드 포인트에 게시합니다. 내가 생성 한 코드는 다음과 같습니다 : - 그것은 akka.stream.scaladsl.Flow[(akka.http.scaladsl.model.HttpRequest, com.cogpp.exp.
첫 번째 항목 이후에 Accka-Stream (오늘 2.11_2.5-SNAPSHOT) Source을 취소 하겠지만 다음과 같은 (단순화 된) 소비자가 있습니다. onNext은 여전히 4 배 : 그 요청을 감안할 때 static Subscriber<Object> println() {
return new Subscriber<Object>() {