[pulsar-client-reactive] branch main updated: Fix race in ReactiveMessagePipelineTest (#87)

[cbornet]

This is an automated email from the ASF dual-hosted git repository.

cbornet pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/pulsar-client-reactive.git


The following commit(s) were added to refs/heads/main by this push:
     new 604174a  Fix race in ReactiveMessagePipelineTest (#87)
604174a is described below

commit 604174a3ef18edabd14404d08fcdc53c07484880
Author: Lari Hotari <lhot...@users.noreply.github.com>
AuthorDate: Wed Dec 7 11:13:51 2022 +0200

    Fix race in ReactiveMessagePipelineTest (#87)
    
    - the test is flaky unless the pipeline is stopped before evaluating 
assertions
---
 .../apache/pulsar/reactive/client/api/ReactiveMessagePipelineTest.java   | 1 +
 1 file changed, 1 insertion(+)

diff --git 
a/pulsar-client-reactive-api/src/test/java/org/apache/pulsar/reactive/client/api/ReactiveMessagePipelineTest.java
 
b/pulsar-client-reactive-api/src/test/java/org/apache/pulsar/reactive/client/api/ReactiveMessagePipelineTest.java
index ea8d548..4b1a776 100644
--- 
a/pulsar-client-reactive-api/src/test/java/org/apache/pulsar/reactive/client/api/ReactiveMessagePipelineTest.java
+++ 
b/pulsar-client-reactive-api/src/test/java/org/apache/pulsar/reactive/client/api/ReactiveMessagePipelineTest.java
@@ -203,6 +203,7 @@ class ReactiveMessagePipelineTest {
                                .handlingTimeout(Duration.ofMillis(5)).build()) 
{
                        pipeline.start();
                        assertThat(latch.await(1, TimeUnit.SECONDS)).isTrue();
+                       pipeline.stop();
                        // 9 messages should have been acked
                        
assertThat(testConsumer.getAcknowledgedMessages()).hasSize(9);
                        // 1 message should have been nacked