CassandraMappingsSourcesDAO { public Flux<MappingSource> retrieveSources(Mapping mapping) { return executor.executeRows(retrieveSourcesStatement.bind() .setString(MAPPING_TYPE, mapping.getType().asPrefix()) .setString(MAPPING_VALUE, mapping.getMappingValue())) .map(row -> MappingSource.parse(row.getString(SOURCE))); } @Inject  CassandraMappingsSourcesDAO(Session session); Mono<Void> addMapping(Mapping mapping, MappingSource source); Flux<MappingSource> retrieveSources(Mapping mapping); Mono<Void> removeAllData();  }
@Test void retrieveSourcesShouldReturnEmptyByDefault() { assertThat(dao.retrieveSources(MAPPING).collectList().block()).isEmpty(); }