@Test void getAllMappingsShouldReturnEmptyByDefault() { assertThat(dao.getAllMappings().collectList().block()).isEmpty(); }
public Flux<Pair<MappingSource, Mapping>> getAllMappings() { return executor.executeRows(retrieveAllMappingsStatement.bind()) .map(row -> Pair.of( MappingSource.fromUser(row.getString(USER), row.getString(DOMAIN)), Mapping.of(row.getString(MAPPING)))); }
CassandraRecipientRewriteTableDAO { public Flux<Pair<MappingSource, Mapping>> getAllMappings() { return executor.executeRows(retrieveAllMappingsStatement.bind()) .map(row -> Pair.of( MappingSource.fromUser(row.getString(USER), row.getString(DOMAIN)), Mapping.of(row.getString(MAPPING)))); } }
CassandraRecipientRewriteTableDAO { public Flux<Pair<MappingSource, Mapping>> getAllMappings() { return executor.executeRows(retrieveAllMappingsStatement.bind()) .map(row -> Pair.of( MappingSource.fromUser(row.getString(USER), row.getString(DOMAIN)), Mapping.of(row.getString(MAPPING)))); } @Inject  CassandraRecipientRewriteTableDAO(Session session, CassandraUtils cassandraUtils); }
CassandraRecipientRewriteTableDAO { public Flux<Pair<MappingSource, Mapping>> getAllMappings() { return executor.executeRows(retrieveAllMappingsStatement.bind()) .map(row -> Pair.of( MappingSource.fromUser(row.getString(USER), row.getString(DOMAIN)), Mapping.of(row.getString(MAPPING)))); } @Inject  CassandraRecipientRewriteTableDAO(Session session, CassandraUtils cassandraUtils); Mono<Void> addMapping(MappingSource source, Mapping mapping); Flux<Pair<MappingSource, Mapping>> getAllMappings(); }
CassandraRecipientRewriteTableDAO { public Flux<Pair<MappingSource, Mapping>> getAllMappings() { return executor.executeRows(retrieveAllMappingsStatement.bind()) .map(row -> Pair.of( MappingSource.fromUser(row.getString(USER), row.getString(DOMAIN)), Mapping.of(row.getString(MAPPING)))); } @Inject  CassandraRecipientRewriteTableDAO(Session session, CassandraUtils cassandraUtils); Mono<Void> addMapping(MappingSource source, Mapping mapping); Flux<Pair<MappingSource, Mapping>> getAllMappings();  }