FxDart 101 › 섹션 14 · 이벤트 스트림 (push) › mergeScan

mergeScan, switchScan & expandEach

각 이벤트를 내부 스트림으로 접어 공유 상태를 만듭니다 — 병합하거나, 전환하거나, 트리를 걷거나. 시드는 내보내지 않습니다.

FxEvents<R> FxEvents<T>.mergeScan<R>(R seed, Stream<R> Function(R acc, T value) accumulator, {int? concurrent}) FxEvents<R> FxEvents<T>.switchScan<R>(R seed, Stream<R> Function(R acc, T value) accumulator) FxEvents<T> FxEvents<T>.expandEach(Stream<T> Function(T value) project, {int? concurrent})

강의

FxEvents.scan은 시드를 먼저 내보낸 뒤 매 누산 값을 내보냅니다 — 풀 레이어 관례이며 scan과 같습니다. mergeScan과 switchScan은 그렇지 않습니다. 시드는 시작 누산기일 뿐, 이벤트가 아닙니다. Rx와 같고, FxEvents.scan에서 온 사람을 놀라게 하는 지점이 바로 이것입니다: 빈 소스는 빈 채로 닫힙니다.

mergeScan(seed, acc)은 각 이벤트를 accumulator(state, value)를 내부 스트림으로 열어 접습니다. 내부가 내보내는 모든 값이 새 상태가 되고 전달됩니다. concurrent: n을 주면 한 번에 최대 n개만 돌고 나머지는 큐에서 기다립니다. 내부들은 상태 변수 하나를 공유합니다 — 가장 최근 내부 방출이 이깁니다. concurrent가 null이면 무제한입니다. 결과는 소스가 닫히고 모든 내부가 끝났을 때 닫힙니다.

switchScan은 취소하는 형제입니다: 새 소스 값이 이전 내부를 진행 도중에 취소하고, 가장 최근 내부 방출(있다면)이 다음 누산기 호출에 건네지는 상태입니다. 소스가 닫힌 뒤에도 현재 내부는 끝까지 갈 수 있습니다.

expandEach는 Rx의 expand이며, 풀 레이어가 이미 그 단어를 이터러블 flatMap에 쓰고 있어 이름이 바뀌었습니다. 모든 소스 값을 내보낸 뒤, 그 값의 project — 그리고 project 자신이 내보내는 모든 값 — 을 재귀적으로, 너비 우선으로 평탄화합니다. 빈 스트림을 결코 돌려주지 않는 project는 종료되지 않습니다. fxdart 이벤트 레이어, Rx의 mergeScan, switchScan, expand를 따랐습니다.

데모 1 · mergeScan — 시드는 침묵한다

데모 2 · switchScan — 새것이 취소한다

직접 해 보기

연습: expandEach, 유한 트리 0 → 1 → 2.

관련 항목: scan — 시드가 내보내집니다 · switchMap / mergeMap — 공유 상태 없는 평탄화 · expand — 풀 쪽의 한 단계 평탄화, 이 연산자가 가져갈 수 없었던 이름