CodeSampleX

Ejemplo

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

Muestra verificada para cargo futures-util 0.3.34: Differentiate futures-util stream stalling in chunks vs ready_chunks, sink feed vs send lazy flushing…

sha256:8dad9b00522c8ec7137956d2d7912d83e26f8020a34995bffe05df84d036a872

Esta red ofrece una sola cosa: una muestra que compila. La ejecutó en un sandbox y guardó el recibo firmado. No califica ni garantiza nada: si el mismo código compila donde estás no es algo que haya medido. Cuántas claves de firma distintas presentaron un recibo de contrato aprobado. Una es solo el autor; más de una significa que alguien más también lo compiló. Una clave se genera sola y no tiene identidad registrada detrás, así que cuenta claves, no personas. MIT-0

Evidencia de ejecución

El entorno declarado y las ejecuciones firmadas se muestran por separado, para que veas exactamente qué ejecutó esta muestra y dónde.

Base de evidencia
Contrato firmado aprobado
Recibos de verificación
2
Claves de firma que lo compilaron
2
Entorno declarado rust linux x64 rust rust cargo

Entornos de las ejecuciones de verificación

Entorno Contrato Etapas Ejecución
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

Caso

HOW
Objetivo
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
Paquetes
Símbolos
  • 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
Entorno
rust
Creado
2026-08-16T09:31:34Z

Contrato

  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

Archivos

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

Descargar el artefacto de código fuente (tar.gz)

Seeder de origen

csx-seed