읽기를 감싸는 커서의 수명

우열 없음 async

요구사항

가짜 데이터베이스 커서를 통해 장부 행 다섯 개를 읽습니다. 커서의 수명은 읽기를 정확히 감싸야 합니다: 읽기가 시작될 때 생성되고, 마지막 행 이후 정확히 한 번 닫힙니다 — 닫힌 뒤에 읽으면 오류를 던지므로, 이 괄호는 실제로 하중을 받습니다. 행들을 출력한 뒤, 증명으로 closed: true를 출력하세요. 커서는 코드에 들어 있습니다; 두 버전 모두 예상 출력 아래에 표시된 줄들을 출력해야 합니다.

예상 출력

2026-08-01  balance 120.00
2026-08-02  balance 84.50
2026-08-03  balance 210.25
2026-08-04  balance 45.00
2026-08-05  balance 99.90
closed: true

나란히 보기

RxDart

import 'package:rxdart/rxdart.dart';

/// A fake database cursor: sequential reads plus a [closed] flag the
/// output can attest to. Reading after close throws.
class LedgerCursor {
  static const _rows = [
    '2026-08-01  balance 120.00',
    '2026-08-02  balance 84.50',
    '2026-08-03  balance 210.25',
    '2026-08-04  balance 45.00',
    '2026-08-05  balance 99.90',
  ];

var closed = false;

int get length => _rows.length;

Future<String> read(int i) async {
    if (closed) throw StateError('read after close');
    await Future<void>.delayed(const Duration(milliseconds: 5));
    return _rows[i];
  }

void close() => closed = true;
}

Future<void> main() async {
  late final LedgerCursor cursor;

// The bracket: the resource is created on listen, read as a stream,
  // and disposed when the stream terminates — however it terminates.
  final rows = await Rx.using<String, LedgerCursor>(
    resourceFactory: () => cursor = LedgerCursor(),
    streamFactory: (c) => Rx.range(0, c.length - 1).asyncMap(c.read),
    disposer: (c) => c.close(),
  ).toList();

rows.forEach(print);
  print('closed: ${cursor.closed}');
}

FxDart

import 'package:fxdart/fxdart.dart';

var closed = false;

int get length => _rows.length;

Future<String> read(int i) async {
    if (closed) throw StateError('read after close');
    await Future<void>.delayed(const Duration(milliseconds: 5));
    return _rows[i];
  }

void close() => closed = true;
}

Future<void> main() async {
  late final LedgerCursor cursor;

// The bracket: the resource is acquired on the first pull, read lazily,
  // and released exactly once — after the last row, or right before an
  // error would propagate.
  final rows = await fxAsync(usingAsync(
    () => cursor = LedgerCursor(),
    (c) => toAsync(Iterable.generate(c.length, c.read)),
    (c) => c.close(),
  )).toList();

rows.forEach(print);
  print('closed: ${cursor.closed}');
}

차이가 나는 이유

대체로 다르지 않습니다 — 둘 다 같은 Rx 아이디어의 포팅이고, FxDart도 그렇게 말합니다: usingAsync는 Rx의 using을 뒤따라 나왔습니다. 모양은 같은 3부 괄호입니다: 획득, 사용, 해제. Rx.using은 스트림이 listen될 때 커서를 만들고 스트림이 종료될 때 disposer를 호출합니다; usingAsync는 첫 풀에서 획득하고 마지막 풀 이후 또는 오류가 전파되기 직전에 정확히 한 번 해제합니다. 둘 다에서 리소스의 수명은 호출자의 스코프가 아니라 시퀀스의 소비에 묶입니다 — 그것이 이 도구의 존재 이유입니다.

가장자리에서 각 모델의 기질이 드러납니다. 스트림 버전의 disposer는 구독 해지 시에도 실행됩니다 — 중간에 취소해도 커서는 닫힙니다. 구독이란 자기만의 생명주기를 지닌 객체이기 때문입니다. 풀 버전에는 구독이 없습니다: 해제는 완료나 오류에서 발동하므로, 이터레이터를 조용히 방치하는 소비자는 해제를 결코 촉발하지 못합니다 — 정직한 관용구는 파이프라인에 한계를 두는 것(take, 또는 이번처럼 유한한 소스)이고, 그러면 완료가, 따라서 해제가 보장됩니다. 여기서는 읽기가 유한하고 끝까지 진행되므로, 양쪽 모두 다섯 번째 행 다음에 커서를 정확히 한 번 닫습니다.

설계상의 무승부입니다: 두 라이브러리가 추상화에 합의하고, 각자의 모델에서 "반복이 끝났다"가 무엇을 의미하는지에서만 갈리는 쌍입니다.

벤치마크

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

FxDart 398 µs

최대 메모리 무승부

RxDart 16.6 MB

FxDart 16.5 MB

N = 10,000

시간 무승부

RxDart 30.8 ms

FxDart 32.2 ms

최대 메모리 무승부

RxDart 24.9 MB

FxDart 25.4 MB

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