Hacktoberfest 2026: los issues que los mantenedores marcaron para octubre, abiertos y aptos para principiantes. Explorar issues de Hacktoberfest

Chunks are skipped when async reads are cancelled during streaming

Abierto
#203 0 comentarios 0 reacciones 0 asignados Ver en GitHub

Los mantenedores suelen responder en 1 día

Nadie ha tomado este issue todavía.

Evaluación

Dificultad
3/5
Tiempo estimado
1-2 días
Aptitud para principiantes
68/100
Tipo de issue
Error
Claridad
Bastante claro
Estado de actividad
Activo
Stack tecnológico
rust
Área
backend

Línea de trabajo

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.

Escrito por el modelo de indexación a partir del texto del issue.

Descripción

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.

Lenguaje dominante
Rust
Estrellas
97
Forks
2
Merge medio
1 d 18 h
PR fusionados (30 d)
4

Preparar el entorno

  • Sin Dockerfile ni archivo de Docker Compose
  • Tiene una plantilla de pull request
  • Sin guía de contribución

Primeros pasos

  1. Lee el issue completo y luego la guía de contribución del proyecto.
  2. Comenta en el issue que vas a ocuparte — evita que dos personas hagan lo mismo.
  3. Haz un fork del repositorio y trabaja en una rama.
  4. Abre un pull request que haga referencia al número del issue.

Más de channable/opsqueue

Todos los issues de channable/opsqueue

Issues similares

Más issues de Rust

Recibe los nuevos issues en tu correo

Un resumen breve de issues de GitHub para principiantes.