흐름 그래프 작성하기

Question

저는 Akka Streams를 가지고 놀았으며 Flow을 생성하고 FlowGraph을 사용하여 연결하는 아이디어를 얻었습니다.

Akka의이 부분은 아직 개발 중이므로 일부 작업이 완료되지 않고 다른 일부 비트가 변경 될 수 있지만 "완료"되지 않은 FlowGraph를 만들 수 있습니다. 즉, Sink - 내 코드의 다른 부분에 전달하여 Flow를 추가하고 마지막으로 Sink를 추가하여 확장해야합니다.

기본적으로 FlowGraphs를 작성할 수는 있지만 어떻게 이해할 수 없습니까? 특히 FlowGraph가 브로드 캐스트를 사용하여 스트림을 분할 한 경우.

감사

Answer 1

다음 주 (12 월) 우리를 위해 문서 작성 될 것입니다, 그래서 akka 더 쉽게 스트림에 이것이 당신이 얻을 도움이되기를 바랍니다! 그 대답은 다음과 같습니다.

기본적으로 FlowGraph 대신 PartialFlowGraph이 필요합니다. 그것들에서 우리는 UndefinedSink과 UndefinedSource의 사용을 허용하고 이후에 "첨부"할 수 있습니다. 귀하의 경우에는, 우리는 또한 정확히 하나의 "실종"싱크를 가지고 그래프를 제작하는 간단한 도우미 빌더를 제공 - 사람들은 그것이 소스와 완전히 것처럼 처리 할 수 ​​있습니다, 아래 참조 :

// for akka-streams 1.0-M1 

    val source = Source() { implicit b ⇒ 
    // prepare an undefined sink, which can be relpaced by a proper sink afterwards 
    val sink = UndefinedSink[Int] 

    // build your processing graph 
    Source(1 to 10) ~> sink 

    // return the undefined sink which you mean to "fill in" afterwards 
    sink 
    } 

    // use the partial graph (source) multiple times, each time with a different sink 
    source.runWith(Sink.ignore) 
    source.runWith(Sink.foreach(x ⇒ println(x))) 

희망이 도움이!