Hacktoberfest 2026: die Issues, die Maintainer für den Oktober markiert haben – offen und einsteigerfreundlich. Hacktoberfest-Issues durchsuchen

Chunks are skipped when async reads are cancelled during streaming

Offen
#203 0 Kommentare 0 Reaktionen 0 zugewiesene Personen Auf GitHub ansehen

Maintainer antworten meist innerhalb von 1 Tag

Dieses Issue hat noch niemand übernommen.

Bewertung

Schwierigkeit
3/5
Geschätzter Aufwand
1-2 Tage
Anfängerfreundlichkeit
68/100
Issue-Typ
Bug
Klarheit
Größtenteils klar
Aktivitätsstatus
Aktiv
Tech-Stack
rust
Bereich
backend

Rechercherichtung

Start by reading ProducerClient.async_stream_submission_chunks() and the regression scenario linked in the issue’s PR discussion. Reproduce cancellation after a chunk is ready but before delivery, then retry the read. Done means the cancelled read leaves that chunk available and subsequent chunks arrive in order.

Vom Indexierungsmodell aus dem Issue-Text verfasst.

Beschreibung

Description

Cancelling a pending anext() on ProducerClient.async_stream_submission_chunks() can consume a completed chunk before Python receives it. Retrying the read may then skip that chunk.

A regression test in PR discussion 1 demonstrates the scenario: make output chunks ready, start a read, cancel it before delivery, then retry. The next read should still yield the first chunk.

Expected behavior

If a read is cancelled before returning a chunk, the chunk should still be returned by the next read. Subsequent chunks should follow in order.

Vorherrschende Sprache
Rust
Sterne
97
Forks
2
Ø Merge
1 T. 18 Std.
Gemergte PRs (30 T.)
4

Entwicklungsumgebung

  • Kein Dockerfile und keine Docker-Compose-Datei
  • Hat eine Pull-Request-Vorlage
  • Kein Beitragsleitfaden

Erste Schritte

  1. Lesen Sie das ganze Issue und danach den Beitragsleitfaden des Projekts.
  2. Schreiben Sie ins Issue, dass Sie es übernehmen — das erspart doppelte Arbeit.
  3. Forken Sie das Repository und arbeiten Sie in einem Branch.
  4. Öffnen Sie einen Pull Request, der die Issue-Nummer nennt.

Mehr aus channable/opsqueue

Alle Issues in channable/opsqueue

Ähnliche Issues

Weitere Issues zu Rust

Neue Issues direkt in Ihr Postfach

Eine kurze Übersicht über anfängerfreundliche GitHub-Issues.