"sky is blue"라는 문자열이 있고 내부 흐름을 그래프 아래로 전파하고 싶은 여러 요소로 나눈다 고 가정 해 보겠습니다.
Source.single("only one element")
.via(Flow.fromFunction(string => string.split(" ").toSeq))
.map(*do something for each word*)
이 코드에서 Flowhas type Flow[String, Seq[String, NotUsed]은 흐름이 정확히 하나의 출력을 가져야하기 때문에 의미가 있습니다.
이 문제를 해결하기위한 Akka Streams 메커니즘이 있습니까?
내가 올바르게 이해한다면 문자열의 각 청크가 스트림의 개별 요소가되기를 원합니다. 이는 mapConcat을 사용하여 수행 할 수 있습니다.
Source.single("only one element")
.mapConcat { string =>
string.split(" ")
}
.map(*do something for each word*)
이 기사는 인터넷에서 수집됩니다. 재 인쇄 할 때 출처를 알려주십시오.
침해가 발생한 경우 연락 주시기 바랍니다[email protected] 삭제
몇 마디 만하겠습니다