@Test void listAllShouldReturnEmptyWhenNone() { assertThat(testee.listAll().toStream()).isEmpty(); }
public Flux<Pair<BucketName, BlobId>> listAll() { return cassandraAsyncExecutor.executeRows(listAll.bind()) .map(row -> Pair.of(BucketName.of(row.getString(BUCKET)), blobIdFactory.from(row.getString(ID)))); }
CassandraBucketDAO { public Flux<Pair<BucketName, BlobId>> listAll() { return cassandraAsyncExecutor.executeRows(listAll.bind()) .map(row -> Pair.of(BucketName.of(row.getString(BUCKET)), blobIdFactory.from(row.getString(ID)))); } }
CassandraBucketDAO { public Flux<Pair<BucketName, BlobId>> listAll() { return cassandraAsyncExecutor.executeRows(listAll.bind()) .map(row -> Pair.of(BucketName.of(row.getString(BUCKET)), blobIdFactory.from(row.getString(ID)))); } @Inject @VisibleForTesting  CassandraBucketDAO(BlobId.Factory blobIdFactory, Session session); }
CassandraBucketDAO { public Flux<Pair<BucketName, BlobId>> listAll() { return cassandraAsyncExecutor.executeRows(listAll.bind()) .map(row -> Pair.of(BucketName.of(row.getString(BUCKET)), blobIdFactory.from(row.getString(ID)))); } @Inject @VisibleForTesting  CassandraBucketDAO(BlobId.Factory blobIdFactory, Session session); Flux<Pair<BucketName, BlobId>> listAll(); }
CassandraBucketDAO { public Flux<Pair<BucketName, BlobId>> listAll() { return cassandraAsyncExecutor.executeRows(listAll.bind()) .map(row -> Pair.of(BucketName.of(row.getString(BUCKET)), blobIdFactory.from(row.getString(ID)))); } @Inject @VisibleForTesting  CassandraBucketDAO(BlobId.Factory blobIdFactory, Session session); Flux<Pair<BucketName, BlobId>> listAll();  }