디바운스 검색

시간이 먼저, 그다음 최신 승리, 그다음 타입 있는 파싱. 체인 하나. RxDart와의 동점은 의도입니다 — 요점은 패키지를 하나 더 쓰지 않아도 된다는 것입니다.

fxEvents(keystrokes) .debounce(Duration) // wait for quiet .switchMap(search) // latest query wins .mapEither((r, hit) => parse) // failure as a Left

강의

검색 상자는 리스트가 아닙니다. 키 입력은 도착할 때 도착하고, 한 무리는 마지막 질의로 접혀야 하며, 다음 질의가 도착했는데도 아직 떠 있는 요청은 취소되어야 합니다 — 그렇지 않으면 느린 "da"가 빠른 "dart"를 덮어씁니다. 그것은 push 일입니다: fxEvents + debounce + switchMap.

같은 일의 RxDart 비교는 동점입니다. rxdart의 debounceTime이 같은 발상입니다. 여기서 FxDart의 주장은 속도가 아닙니다 — 기다림을 이길 수는 없습니다 — 이벤트 층이 pull 파이프라인 및 타입 있는 에러와 같은 import에 있어서, 다음 단계 (히트를 파싱하고, throw 대신 Left를 남기기)가 새 라이브러리를 열지 않는다는 것입니다.

mapEither는 전달된 각 결과를 raise 스코프에서 돌립니다. 나쁜 페이로드는 Left가 되고, 이후 질의는 그대로 도착합니다. 소스에 attempt를 두는 것은 throw가 값이 되어야 할 때뿐입니다 — 체인이 재시도도 한다면 attempt는 다음 retryOn, 앞이 아닙니다.

데모 1 · 타이핑이 잦아들 때까지

키 입력 일정은 시뮬레이션입니다: 한 무리, 멈춤, 질의 하나 더. debounce(160ms)는 두 번 방출합니다 — fxd와 fxdart — 비교 페이지와 같은 계약입니다.

데모 2 · 최신 질의가 이기고, 그다음 타입 있는 파싱

switchMap은 질의마다 검색을 시작하고 이전 안쪽 스트림을 취소합니다. mapEither는 빠진 히트를 throw가 아니라 Left로 이름 붙입니다. 검색은 둘 다 시작되고, 전달되는 결과는 최신뿐입니다.

import 'dart:async';

import 'package:fxdart/fxdart.dart';

/// Emits each (offsetMs, value) pair at its offset, closing at [closeMs].
Stream<T> timed<T>(List<(int, T)> events, int closeMs) {
  final c = StreamController<T>();
  for (final (ms, v) in events) {
    Timer(Duration(milliseconds: ms), () => c.add(v));
  }
  Timer(Duration(milliseconds: closeMs), c.close);
  return c.stream;
}

Future<void> main() async {
  // The user refines the query while the first search is still in flight.
  final queries = timed([(0, 'da'), (60, 'dart')], 400);
  final started = <String>[];

Stream<String> search(String q) {
    started.add(q);
    return timed([(150, 'hits for "$q"')], 200);
  }

final out = await fxEvents(queries)
      .switchMap(search)
      .mapEither<String, String>(
        (r, hit) => r.ensureNotNull(
          hit.startsWith('hits') ? hit : null,
          () => 'empty: $hit',
        ),
      )
      .toList();

print('started:   $started'); // [da, dart]
  print('delivered: $out'); // [Right(hits for "dart")]
}

관련: 어느 표면 — 이것이 push인 이유 · fxEvents · debounce · switchMap · mapEither · 한도 있는 동시 fetch — I/O 일 · RxDart vs FxDart: debounce