@Test void retrieveBucketsShouldReturnEmptyWhenNone() { assertThat(testee.retrieveBuckets().toStream()).isEmpty(); }
Flux<BucketName> retrieveBuckets() { return cassandraAsyncExecutor.executeRows(listBucketsStatement.bind()) .map(row -> row.getString(BUCKET_NAME)) .map(BucketName::of); }
UserPerBucketDAO { Flux<BucketName> retrieveBuckets() { return cassandraAsyncExecutor.executeRows(listBucketsStatement.bind()) .map(row -> row.getString(BUCKET_NAME)) .map(BucketName::of); } }
UserPerBucketDAO { Flux<BucketName> retrieveBuckets() { return cassandraAsyncExecutor.executeRows(listBucketsStatement.bind()) .map(row -> row.getString(BUCKET_NAME)) .map(BucketName::of); } @Inject  UserPerBucketDAO(Session session); }
UserPerBucketDAO { Flux<BucketName> retrieveBuckets() { return cassandraAsyncExecutor.executeRows(listBucketsStatement.bind()) .map(row -> row.getString(BUCKET_NAME)) .map(BucketName::of); } @Inject  UserPerBucketDAO(Session session);  }
UserPerBucketDAO { Flux<BucketName> retrieveBuckets() { return cassandraAsyncExecutor.executeRows(listBucketsStatement.bind()) .map(row -> row.getString(BUCKET_NAME)) .map(BucketName::of); } @Inject  UserPerBucketDAO(Session session);   }