Open
Description
openedon Jul 9, 2024
Describe the bug
Having a grpc service which returns Multi and grpc client which is cancelled after some time, grpc service continue to produce items (looks similar to #13988)
public Multi<GreetingResponse> greeting(Empty request) {
return Multi.createFrom().ticks().every(
Duration.ofSeconds(2)).invoke(x -> {
System.out.println(Thread.currentThread().getName() + "-" + Instant.now().getEpochSecond());
})
.onItem().transform(x -> GreetingResponse.newBuilder().setId(x).build());
}
Expected behavior
Grpc service is cancelled
Actual behavior
Grpc service continue to produce messages
How to Reproduce?
No response
Output of uname -a
or ver
22.04.2-Ubuntu
Output of java -version
Temurin-21.0.2+13
Quarkus version or git rev
3.11.0
Build tool (ie. output of mvnw --version
or gradlew --version
)
Gradle 8.6
Additional information
No response
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Metadata
Assignees
Type
Projects
Status
Out of scope