@Test
void subscribeTopicQueryPreEpochStartTime() {

    TopicMessage topicMessage1 = domainBuilder.topicMessage().block();
    TopicMessage topicMessage2 = domainBuilder.topicMessage().block();
    TopicMessage topicMessage3 = domainBuilder.topicMessage().block();
    ConsensusTopicQuery query = ConsensusTopicQuery.newBuilder()
            .setLimit(5L)
            .setConsensusStartTime(Timestamp.newBuilder().setSeconds(-123).setNanos(-456).build())
            .setTopicID(TopicID.newBuilder().setRealmNum(0).setTopicNum(0).build())
            .build();
    Flux<TopicMessage> generator = domainBuilder.topicMessages(2, Instant.now().plusSeconds(10L));
    grpcConsensusService.subscribeTopic(Mono.just(query))
            .as(StepVerifier::create)
            .expectNext(topicMessage1.toResponse())
            .expectNext(topicMessage2.toResponse())
            .expectNext(topicMessage3.toResponse())
            .thenAwait(Duration.ofMillis(50))
            .then(() -> generator.blockLast())
            .expectNextCount(2)
            .expectComplete()
            .verify(Duration.ofMillis(500));
}