Skip to content

Mutiny subscription is not cancelled when grpc client is cancelled #41776

Open

Description

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

No one assigned

    Type

    No type

    Projects

    • Status

      Out of scope

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions