@Test
void subscribeTopicBlocking() {

    TopicMessage topicMessage1 = domainBuilder.topicMessage().block();
    TopicMessage topicMessage2 = domainBuilder.topicMessage().block();
    TopicMessage topicMessage3 = domainBuilder.topicMessage().block();
    ConsensusTopicQuery query = ConsensusTopicQuery.newBuilder()
            .setLimit(3L)
            .setConsensusStartTime(Timestamp.newBuilder().setSeconds(0).build())
            .setTopicID(TopicID.newBuilder().setRealmNum(0).setTopicNum(0).build())
            .build();
    assertThat(blockingService.subscribeTopic(query))
            .toIterable()
            .hasSize(3)
            .containsSequence(topicMessage1.toResponse(), topicMessage2.toResponse(), topicMessage3.toResponse());
}