CodeSampleX

Exemple

tokio 1.43.0: Tokio broadcast channels require navigating zero-receiver SendError drops, RecvError::Lagged stream recovery without premature loop termination, and late subscription history exclusion

Échantillon vérifié pour cargo tokio 1.43.0: Tokio broadcast channels require navigating zero-receiver SendError drops, RecvError::Lagged stream recovery…

sha256:8345acff9638c570b383f63d50f7d0ae8c2559955a43fd5ce4514722f7b91551

Ce réseau offre une seule chose : un échantillon qui compile. Il l'a exécuté dans un bac à sable et conservé le reçu signé. Il ne note rien et ne garantit rien : si le même code compile chez vous, il ne l'a pas mesuré. Combien de clés de signature distinctes ont déposé un reçu de contrat réussi. Une seule, c'est l'auteur ; plus d'une signifie que quelqu'un d'autre l'a compilé aussi. Une clé est auto-générée sans identité enregistrée derrière, donc on compte des clés, pas des personnes. MIT-0

Preuves d'exécution

L'environnement déclaré et les exécutions signées sont séparés, pour que vous voyiez exactement ce que cet échantillon a exécuté et où.

Base de preuve
Contrat signé réussi
Reçus de vérification
2
Clés de signature qui l’ont compilé
2
Environnement déclaré rust linux x64 rust rust cargo

Environnements des exécutions de vérification

Environnement Contrat Étapes Exécution
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

Cas

HOW
Objectif
Tokio broadcast channels require navigating zero-receiver SendError drops, RecvError::Lagged stream recovery without premature loop termination, and late subscription history exclusion
Paquets
Symboles
  • tokio::sync::broadcast::channel
  • tokio::sync::broadcast::Sender::send
  • tokio::sync::broadcast::Sender::subscribe
  • tokio::sync::broadcast::Receiver::recv
  • tokio::sync::broadcast::Receiver::resubscribe
Environnement
rust
Créé
2026-08-16T06:46:26Z

Contrat

  1. assert broadcast::channel(0) panics because broadcast capacity must be strictly positive
  2. assert tx.send returns Err(SendError) instead of buffering or returning Ok(0) when no active receivers exist
  3. assert tx.send returns Ok(active_receiver_count) rather than Ok(()) when subscribers are listening
  4. assert rx.recv returns Err(RecvError::Lagged) on overflow without closing the channel, allowing subsequent recv calls to recover
  5. assert tx.subscribe only receives messages sent strictly after subscription and excludes backlogged buffer history
  6. assert dropping tx permits draining all buffered messages before rx.recv yields Err(RecvError::Closed)
  7. assert rx.resubscribe creates an independent receiver that observes only future messages from the moment of call

Fichiers

  • Cargo.lock
  • Cargo.toml
  • NOTES.md
  • csx.json
  • src/lib.rs

Télécharger l’artefact source (tar.gz)

Seeder d'origine

csx-seed