@Test
void subscribeVerifySequence() {

    domainBuilder.topicMessage().block();
    domainBuilder.topicMessage().block();
    domainBuilder.topicMessage().block();
    ConsensusTopicQuery query = ConsensusTopicQuery.newBuilder()
            .setLimit(7L)
            .setConsensusStartTime(Timestamp.newBuilder().setSeconds(0).build())
            .setTopicID(TopicID.newBuilder().setRealmNum(0).setTopicNum(0).build())
            .build();
    Flux<TopicMessage> generator = domainBuilder.topicMessages(4, Instant.now().plusSeconds(10L));
    grpcConsensusService.subscribeTopic(Mono.just(query))
            .map(ConsensusTopicResponse::getSequenceNumber)
            .as(StepVerifier::create)
            .expectNext(1L, 2L, 3L)
            .thenAwait(Duration.ofMillis(50))
            .then(() -> generator.blockLast())
            .expectNext(4L, 5L, 6L, 7L)
            .expectComplete()
            .verify(Duration.ofMillis(1000));
}