CodeSampleX

샘플

pool 1.5.2: Run at most N async operations at once in Dart with package:pool, keep the results lined up with the inputs, and know what the timeout actually guards

검증된 샘플 — pub pool 1.5.2: Run at most N async operations at once in Dart with package:pool, keep the results lined up with the inputs, and know what the…

sha256:16a15d010dc0f1c9e1ee0824cafd5bd1ed1eb32530f108bc856e8cc348fa9179

이 네트워크가 제공하는 것은 하나입니다. 빌드되는 샘플. 샌드박스에서 돌리고 서명된 영수증을 보관합니다. 등급을 매기지 않고 무엇도 보증하지 않습니다 — 같은 코드가 당신 환경에서 빌드되는지는 측정한 적이 없습니다. 통과한 계약 영수증을 낸 서로 다른 서명 키의 수입니다. 하나면 작성자 혼자이고, 둘 이상이면 다른 사람도 빌드했다는 뜻입니다. 키는 스스로 만드는 것이고 뒤에 등록된 신원이 없으므로, 세는 것은 사람이 아니라 키입니다. MIT-0

실행 증거

선언된 환경과 서명된 실행을 분리해 두었습니다. 이 샘플이 무엇을 어디서 실행했는지 그대로 볼 수 있습니다.

증거 기준
서명된 컨트랙트 통과
검증 영수증
1
빌드한 서명 키
1
선언된 환경 dart 3 linux x64 dart 3 dart pub

검증 실행 환경

환경 컨트랙트 단계 실행일
dart 3 · linux alpine/x64 · docker ed25519:a2ec939a4c60e243 PASS compile:SKIPPED · contract:PASS · load:PASS · resolve:PASS
CONTAINER_RUN · pub@1
2026-08-14

케이스

HOW
목표
Run at most N async operations at once in Dart with package:pool, keep the results lined up with the inputs, and know what the timeout actually guards
패키지
심벌
  • Pool
  • Pool.withResource
  • Pool.request
  • Pool.forEach
  • Pool.close
  • Pool.done
  • Pool.isClosed
  • PoolResource
  • PoolResource.release
  • PoolResource.allowRelease
  • TimeoutException
환경
dart 3
생성일
2026-08-14T20:09:50Z

컨트랙트

  1. assert a Pool of two runs at most two bodies at once, and that a withResource body that throws still releases its slot, so the high-water mark afterwards is two and not one
  2. assert pool.forEach emits results in completion order rather than input order, so its list is a permutation of the inputs, while Future.wait over withResource keeps every result in position
  3. assert forEach holds every resource in the pool for the whole run, so an unrelated request on the same pool is blocked outright rather than throttled alongside it
  4. assert the default onError adds the error to the stream and carries on, and that returning false only drops the error, with all six elements processed either way
  5. assert toList on a forEach stream completes with the first error, discards the values already emitted and cancels the iteration, so the remaining elements are never attempted
  6. assert an error thrown while iterating the elements bypasses onError entirely and lands on the stream even when onError returns false
  7. assert the timeout is a pool-wide inactivity alarm that any request or release resets, so a starved caller waits nearly three times it, that it then fails every pending request at once with a TimeoutException carrying the configured duration, and that it never fires again for the life of the pool
  8. assert request() throws StateError synchronously on a closed pool while withResource puts the identical error into its returned future instead, and that close() is memoized to one future
  9. assert done completes only once the resources handed out before close are released
  10. assert allowRelease spends the resource token so a following release() throws StateError, that its callback runs only when the slot is wanted, and that a callback which throws completes the next caller's request() with that error and leaves the pool one usable resource short forever
  11. assert queued requests are answered in request order even when it is a later allowRelease callback that frees the slot
  12. assert Pool(0) and a negative limit throw ArgumentError from the constructor, and that queued waiters are served first in, first out

파일

  • csx.json
  • lib/throttle.dart
  • pubspec.lock
  • pubspec.yaml
  • test/contract_test.dart

소스 아티팩트 내려받기 (tar.gz)

오리진 시더

anonymous