세 번 실패하면 포기하기

FxDart 승 async

요구사항

헬스 프로브 열 개의 피드가 순서대로 실행됩니다; 프로브 2, 5, 7, 8, 9가 오류를 던집니다. 세 번째 실패가 보이는 순간(그것을 포함하여) 실행을 멈춘 뒤 세 가지 수치를 출력하세요: processed — 중단 전에 파이프라인에 들어온 프로브 수; failures — 그중 오류를 던진 수; probes run — 실제로 실행된 프로브 본문 수로, 프로브 자체 안의 부수효과 카운터로 집계합니다. 뒤쪽 프로브들은 결코 실행되면 안 되므로, 실행 수는 처리 수와 일치해야 합니다. 스케줄은 코드에 들어 있습니다; 두 버전 모두 예상 출력 아래에 표시된 줄들을 출력해야 합니다.

예상 출력

processed: 7
failures: 3
probes run: 7

나란히 보기

RxDart

import 'package:rxdart/rxdart.dart';

const probeIds = [1, 2, 3, 4, 5, 6, 7, 8, 9, 10];
const failing = {2, 5, 7, 8, 9};

int runs = 0;

// One health probe — throws when the endpoint is down.
Future<void> probe(int id) async {
  runs++;
  await Future.delayed(const Duration(milliseconds: 5));
  if (failing.contains(id)) throw StateError('probe $id failed');
}

Future<void> main() async {
  // Failures must become data before scan can count them — each probe
  // gets an inner stream that recovers the error as a marker value.
  final states = await Stream.fromIterable(probeIds)
      .asyncExpand((id) => Rx.fromCallable(() async {
            await probe(id);
            return true;
          }).onErrorReturn(false))
      .scan<({int done, int fails})>(
          (acc, ok, _) => (done: acc.done + 1, fails: acc.fails + (ok ? 0 : 1)),
          (done: 0, fails: 0))
      .takeWhileInclusive((s) => s.fails < 3)
      .toList();

final last = states.last;
  print('processed: ${last.done}');
  print('failures: ${last.fails}');
  print('probes run: $runs');
}

FxDart

차이가 나는 이유

세는 핵심부는 양쪽이 같습니다 — scan이 진행 중인 (done, fails) 상태를 접고, 포함형 take 연산자가 세 번째 실패에서 파이프라인을 자릅니다(한쪽은 takeUntilInclusive(fails == 3), 다른 쪽은 takeWhileInclusive(fails < 3)). 양쪽 모두 일을 진짜로 멈추기도 합니다: probes run: 7은 구독 취소와 풀 중단이 똑같이 효과적인 브레이크임을 증명합니다.

차이는 scan이 셀 수 있게 되기 전에 각 쪽이 해야 했던 일입니다. 오류를 던진 프로브는 스트림의 오류 채널에 사는데, 거기는 scan이 볼 수 없는 곳이고 — 실패 1번에서 스트림을 끝내 버릴 곳이기도 합니다. 그래서 RxDart 쪽은 먼저 모든 프로브를 내부 스트림(Rx.fromCallable + onErrorReturn(false))으로 변환해, 실패를 마커 값으로 데이터 채널에 몰래 되돌려 보냅니다. FxDart 쪽에는 변환 단계가 필요 없습니다. 변환해 올 출처가 없기 때문입니다: map 안의 try/catch가 결과를 사건이 일어난 바로 그 자리에서 bool로 만들고, 파이프라인의 나머지는 산수입니다. 같은 연산자들, 건너야 할 모델 경계는 하나 더 적게.

벤치마크

Apple M1 Max, RAM 32 GB · Dart 3.12.2 (AOT 컴파일) · 2026-08-18

비동기 예제입니다. 대표 스케일이 1,000,000이 아니라 N = 10,000인 이유 — 원소 하나마다 양쪽 모두 이벤트 루프를 한 바퀴 돌아야 하므로, 실제 await 백만 번은 파이프라인이 아니라 Dart 이벤트 루프를 몇 분씩 재게 됩니다. 지연은 0으로 두고 예제의 동시성 제한은 그대로 유지합니다. 막대가 비교하는 것은 파이프라인 기계 장치 자체입니다.

N = 100

시간 무승부

RxDart 818 µs

FxDart 413 µs

최대 메모리 무승부

RxDart 16.6 MB

FxDart 17.0 MB

N = 10,000

시간 FxDart 승

RxDart 65.5 ms

FxDart 37.6 ms

최대 메모리 무승부

RxDart 22.2 MB

FxDart 22.6 MB

막대는 사이드별로 새 프로세스에서 반복 측정한 중앙값입니다(작은 N은 타이머 해상도를 위해 배치 처리). 두 사이드가 서로 5% 이내이거나 — 사람이 지각할 수 없는 차이인 0.6ms 이내이면 — 무승부로 칩니다. 상대 차이가 근소한 경우는 최대 5회까지 다시 측정합니다. 앱에서는 어느 막대가 짧든 몇 밀리초 이하의 차이는 사용자에게 보이지 않습니다. 메모리는 프로세스 최대 RSS입니다. Dart VM과 데이터셋은 양쪽이 동일하므로, 두 막대의 차이가 곧 파이프라인 자체가 붙들고 있는 양입니다.