Expected a completion event, but didn't received it

[softshipper]

Hi all,
I use Mutiny in combination with https://quarkus.io/guides/reactive-sql-clients.
When I do the following query to the database with the assertion:

val subscriber = client.query("SELECT * FROM company")
    .execute()
    .map { it.take(1).first().getString("open_id") }
    .subscribe()
    .withSubscriber(UniAssertSubscriber.create())

subscriber
    .awaitSubscription(Duration.ofSeconds(3))
    .assertCompleted()
    .assertItem("AUTH2")

I have got:

Expected a completion event, but didn't received it.
java.lang.AssertionError: 
Expected a completion event, but didn't received it.
	at io.smallrye.mutiny.helpers.test.AssertionHelper.fail(AssertionHelper.java:146)
	at io.smallrye.mutiny.helpers.test.AssertionHelper.shouldHaveCompleted(AssertionHelper.java:24)
	at io.smallrye.mutiny.helpers.test.UniAssertSubscriber.assertCompleted(UniAssertSubscriber.java:315)
	at io.acme.ExampleResourceTest.test3(ExampleResourceTest.kt:54)
	at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
	at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.base/java.lang.reflect.Method.invoke(Method.java:568)
	at io.quarkus.test.junit.QuarkusTestExtension.runExtensionMethod(QuarkusTestExtension.java:1086)
	at io.quarkus.test.junit.QuarkusTestExtension.interceptTestMethod(QuarkusTestExtension.java:905)

Unfortunately, I could not figure out why I do not receive the completion event.

Calling the method await instead of subscribe it yields the expected result:

val result = client.query("SELECT * FROM company")
    .execute()
    .map {
        it.take(1).first().getString("open_id")
    }
    .await()
    .atMost(Duration.ofSeconds(3))

Assertions.assertEquals(result, "AUTH2")

What is wrong with subscribe?

PS: The code is written in Kotlin. Anyway, it is not different than in Java.

Best regards

[cescoffier]

assertCompletion verifies that you already received the completion event. In your case, it's not the case, it's still in process. Use awaitItem instead. It awaits for the emission of the item. The default timeout is 10s, which should be enough.

[softshipper]

As suggested on https://smallrye.io/smallrye-mutiny/1.7.0/guides/testing/ it is not clear for a newbie that I should use awaitItem instead of assertCompleted.

Best regards

[cescoffier]

Agreed, we should use awaitItem on the doc.

Cc @jponge

[jponge]

@softshipper Do you want to contribute a PR?

[jponge]

Done #1077

[softshipper]

@jponge Sorry for the late response. What is PR exactly ?

[jponge]

To update the docs, but I've done it yesterday :-)

…

Message ID: ***@***.*** com>

[softshipper]

thanks a lot