FluxTest.java

@Slf4j
public class FluxTest {

    @Test
    public void test() {

        Flux<String> b = Flux.just("Bob cat", "is in the ", "party").delayElements(Duration.ofSeconds(2));

        Flux.first(b)
                .toIterable()
                .forEach(log::info);
    }
}

//14:43:31.455 [main] INFO com.capitalone.fs.marketingone.FluxTest - Bob cat
//14:43:33.460 [main] INFO com.capitalone.fs.marketingone.FluxTest - is in the 
//14:43:35.463 [main] INFO com.capitalone.fs.marketingone.FluxTest - party

Hi,

why not testing with StepVerifier ?

@Test
void fluxElements() {
       final Flux<String> elements = Flux.just("Bob cat", "is in the", "party");
       StepVerifier.withVirtualTime(() -> elements
               .delayElements(Duration.ofSeconds(2)))
               .expectSubscription()
               .thenAwait(Duration.ofSeconds(6))
               .expectNextMatches(predicate -> predicate.equals("Bob cat"))
               .expectNextMatches(predicate -> predicate.equals("is in the"))
               .expectNextMatches(predicate -> predicate.equals("party"))
               .verifyComplete();
}