최근 오류 메시지, 중복 제거

FxDart 승

요구사항

로그 저장소는 항목을 최신순으로 반환합니다. 가장 최근의 서로 다른 오류 메시지 세 개를 표시하세요: ERROR 항목만 남기고, 이미 표시한 메시지의 반복은 제거하고, 세 개가 되면 멈춥니다. 데이터는 아래 코드에 있으며, 두 버전 모두 예상 출력 아래에 표시된 줄을 출력해야 합니다.

예상 출력

09:41 payment gateway timeout
09:31 inventory service 503
09:17 invalid session token

나란히 보기

네이티브 Dart

FxDart

import 'package:fxdart/fxdart.dart';

class Log {
  final String time;
  final String level;
  final String message;
  const Log(this.time, this.level, this.message);
}

// Newest first, as a log store would return them.
const logs = [
  Log('09:41', 'ERROR', 'payment gateway timeout'),
  Log('09:40', 'INFO', 'checkout started'),
  Log('09:38', 'ERROR', 'payment gateway timeout'),
  Log('09:35', 'WARN', 'retrying request'),
  Log('09:31', 'ERROR', 'inventory service 503'),
  Log('09:28', 'INFO', 'cache warmed'),
  Log('09:22', 'ERROR', 'payment gateway timeout'),
  Log('09:17', 'ERROR', 'invalid session token'),
  Log('09:12', 'ERROR', 'disk quota exceeded'),
  Log('09:05', 'INFO', 'server started'),
];

/// The same three rows in one strict pass, for when the pipeline is hot.
///
/// A lazy stage keeps its callback in an iterator field, and the AOT compiler
/// cannot see through a field — so neither closure in `main` below is ever
/// inlined, and the two calls per element are most of what separates this
/// pipeline from a hand-written loop. `takeUniqBy` takes its callback as a
/// parameter of a function small enough to inline into the caller, so the
/// compiler inlines the closure body with it. One callback does both jobs
/// here: a `null` key means "skip this element".
///
/// Over 1,000,000 log lines, AOT: **13.9 ms** for the chain in `main`,
/// **11.2 ms** for this, **10.4 ms** for the hand-written loop the native
/// panel shows. Reach for it when a profile says these callbacks are the
/// cost; the chain below is what reads, and it is the one to write by
/// default.
List<Log> recentErrorsStrict() =>
    takeUniqBy(3, (l) => l.level == 'ERROR' ? l.message : null, logs);

void main() {
  // The composable form: three independent steps, each readable on its own,
  // and lazy — `take(3)` stops the scan at the third distinct message.
  final recent = fx(logs)
      .filter((l) => l.level == 'ERROR')
      .uniqBy((l) => l.message)
      .take(3);
  for (final l in recent) {
    print('${l.time} ${l.message}');
  }
}

차이가 나는 이유

Dart에는 "키 기준 distinct"가 없습니다 — 메시지 기준으로 중복을 제거하려면 Set을 직접 관리해야 하므로, 네이티브 버전은 세 가지 관심사가 얽힌 루프가 됩니다: 레벨 확인, seen.add 트릭, 그리고 개수를 세는 break. 각각은 그 자체로는 문제없지만, 함께 있으면 무엇을 남기는지 알기 위해 루프 전체를 읽어야 합니다. FxDart는 이 세 가지 규칙을 체인의 세 단계 — filter, uniqBy, take — 로 표현하며, 체인이 지연 평가되므로 세 번째 서로 다른 오류를 찾는 즉시 로그 스캔을 멈춥니다. 손으로 작성한 break와 정확히 동일하게 동작합니다.

FxDart의 두 가지 표현

이 페이지의 벤치마크에는 다른 비교 페이지에 없는 세 번째 막대가 있습니다. 위의 체인이 기본으로 쓸 형태입니다 — 세 규칙이 위에서 아래로 읽히고, 지연 평가라서 세 번째 서로 다른 오류를 찾는 순간 스캔을 멈춥니다. 손으로 쓴 break와 똑같습니다. 다만 이 형태가 못 하는 것이 하나 있습니다: 자기 콜백을 인라인하지 못합니다. 지연 단계는 클로저를 이터레이터의 필드에 담아 두는데 AOT 컴파일러는 필드 너머를 보지 못하므로, filter와 uniqBy가 원소마다 실제 간접 호출을 한 번씩 냅니다. 이 파이프라인과 네이티브 루프를 갈라놓는 것의 대부분이 그 두 호출입니다.

FxDart 패널의 main 위에 있는 takeUniqBy는 같은 파이프라인을 하나의 즉시(strict) 호출로 쓴 것입니다. 콜백이 호출자에 인라인될 만큼 작은 본문의 매개변수라서, 컴파일러가 클로저 본문을 함께 인라인합니다. 콜백 하나가 두 일을 겸하며, 키가 null이면 "이 원소는 건너뛴다"는 뜻입니다. 로그 100만 줄에서 두 번째 막대와 세 번째 막대의 차이가 바로 그것이고, 첫 번째 막대가 네이티브 루프입니다.

기본은 체인으로 쓰십시오. 파이프라인이 뜨거운 경로에 있고 프로파일이 이 콜백들을 지목할 때 takeUniqBy를 꺼내면 됩니다.

벤치마크

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

N = 100

시간 무승부

네이티브 Dart 1.0 µs

FxDart 1.3 µs

최대 메모리 무승부

네이티브 Dart 16.5 MB

FxDart 16.5 MB

N = 10,000

시간 무승부

네이티브 Dart 90 µs

FxDart 127 µs

최대 메모리 무승부

네이티브 Dart 15.8 MB

FxDart 15.8 MB

N = 1,000,000

시간 네이티브 승

네이티브 Dart 10.3 ms

FxDart 13.7 ms

최대 메모리 무승부

네이티브 Dart 114.3 MB

FxDart 113.5 MB

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