CassandraEventDeadLettersGroupDAO { Flux<Group> retrieveAllGroups() { return executor.executeRows(selectAllStatement.bind()) .map(Throwing.function(row -> Group.deserialize(row.getString(GROUP)))); } @Inject  CassandraEventDeadLettersGroupDAO(Session session);   }
@Test void retrieveAllGroupsShouldReturnEmptyWhenDefault() { assertThat(GROUP_DAO.retrieveAllGroups() .collectList().block()) .isEmpty(); }