스트림이 타입 있는 파이프라인으로 흘러들 때

우열 없음 async

요구사항

라이브 로그 피드가 고정 스케줄로 일곱 줄을 내보내고 닫힙니다. 경고만 남기고, 인시던트 채널용으로 대문자로 바꾸고, 마지막 개수와 함께 출력하세요. 피드는 코드에 (양쪽에 동일하게) 시뮬레이션되어 있습니다; 두 버전 모두 예상 출력 아래에 표시된 줄들을 출력해야 합니다.

예상 출력

WARN: DISK 81% FULL
WARN: LATENCY 900MS
WARN: RETRY QUEUE AT 12
warnings: 3

나란히 보기

RxDart

FxDart

차이가 나는 이유

거의 다르지 않습니다 — 그리고 그것이 이 쌍의 요점입니다. 소스는 푸시 본연의 것, 내키는 대로 값을 내보내는 Stream이고, RxDart는 그 모델 안에 머뭅니다: mapNotNull이 필터링과 포매팅을 연산자 하나로 하고, toList가 닫힐 때 수집합니다. 깨끗하고, 관용적이고, 끝.

FxDart 쪽은 스트림과 싸우지도, 소스를 다시 모델링하지도 않습니다 — 브리지합니다. fxStream은 어떤 Stream이든 풀 기반 비동기 이터러블로 감싸고, 그 지점부터 코드는 리스트 위에 쓸 법한 것과 같은 타입 있는 체인입니다: filter, map, toList. 브리지는 밀려온 이벤트를 파이프라인이 요구할 때까지 버퍼링하므로, 아무것도 잃지 않고 순서도 보존됩니다. 이것은 대결이 아니라 협력의 예제입니다: 이벤트가 태어나는 가장자리에서는 스트림을 스트림으로 두고, 타입 있는 요구 주도 처리를 원하는 순간에 풀 파이프라인으로 건너오세요 — 두 모델은 한 줄로 합성됩니다. 무승부, 그것도 의도된 무승부입니다.

벤치마크

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 8.9 µs

FxDart 8.8 µs

최대 메모리 무승부

RxDart 16.5 MB

FxDart 16.5 MB

N = 10,000

시간 무승부

RxDart 762 µs

FxDart 773 µs

최대 메모리 무승부

RxDart 22.9 MB

FxDart 23.5 MB

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