UserPerBucketDAO { Flux<Username> retrieveUsers(BucketName bucketName) { return cassandraAsyncExecutor.executeRows(listStatement.bind() .setString(BUCKET_NAME, bucketName.asString())) .map(row -> row.getString(USER)) .map(Username::of); } @Inject  UserPerBucketDAO(Session session);   }
@Test void retrieveUsersShouldReturnEmptyWhenNone() { assertThat(testee.retrieveUsers(BUCKET_NAME).toStream()).isEmpty(); }