CodeSampleX

샘플

futures-util 0.3.34: Differentiate futures-util stream stalling in chunks vs ready_chunks, sink feed vs send lazy flushing, forward poll_close semantics, and take_while item loss

검증된 샘플 — cargo futures-util 0.3.34: Differentiate futures-util stream stalling in chunks vs ready_chunks, sink feed vs send lazy flushing, forward poll_close…

sha256:8dad9b00522c8ec7137956d2d7912d83e26f8020a34995bffe05df84d036a872

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

실행 증거

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

증거 기준
서명된 컨트랙트 통과
검증 영수증
2
빌드한 서명 키
2
선언된 환경 rust linux x64 rust rust cargo

검증 실행 환경

환경 컨트랙트 단계 실행일
rust 1 · linux alpine/x64 · docker ed25519:d91480838ac982c9 PASS compile:SKIPPED · contract:PASS · load:PASS · resolve:PASS
CONTAINER_RUN · cargo@1
2026-08-16
rust 1 · linux alpine/x64 · docker ed25519:2175b912ea1c23b1 PASS compile:SKIPPED · contract:PASS · load:PASS · resolve:PASS
CONTAINER_RUN · cargo@1
2026-08-18

케이스

HOW
목표
Differentiate futures-util stream stalling in chunks vs ready_chunks, sink feed vs send lazy flushing, forward poll_close semantics, and take_while item loss
패키지
심벌
  • futures_util::stream::StreamExt::ready_chunks
  • futures_util::stream::StreamExt::chunks
  • futures_util::stream::StreamExt::forward
  • futures_util::sink::SinkExt::feed
  • futures_util::stream::StreamExt::take_while
  • futures_util::stream::StreamExt::buffered
  • futures_util::stream::StreamExt::buffer_unordered
  • futures_util::select_biased
  • futures_util::stream::FuturesUnordered
  • futures_util::future::Abortable
환경
rust
생성일
2026-08-16T09:31:34Z

컨트랙트

  1. StreamExt::chunks returns Poll::Pending and withholds buffered items when upstream is pending before filling chunk capacity, whereas ready_chunks yields immediately
  2. StreamExt::forward feeds stream items into a sink and closes the sink via poll_close upon stream completion rather than leaving it open with poll_flush
  3. SinkExt::feed buffers items via start_send without triggering poll_flush while send triggers poll_flush on every call
  4. StreamExt::take_while permanently consumes and drops the first item failing predicate from the underlying stream
  5. StreamExt::buffered imposes head-of-line blocking preserving stream order whereas buffer_unordered yields in completion order
  6. select_biased! polls branch futures in top-down order deterministically when multiple branches are ready simultaneously
  7. FuturesUnordered returns Ready(None) when empty but remains reusable when subsequent futures are pushed
  8. Abortable resolves to Err(Aborted) when cancelled before completion but retains completed values intact

파일

  • Cargo.lock
  • Cargo.toml
  • NOTES.md
  • csx.json
  • src/custom_sink.rs
  • src/lib.rs
  • src/step_stream.rs
  • tests/futures_util_traps.rs

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

오리진 시더

csx-seed