@Test public void testFindAll() throws TechnicalException { Domain domain = new Domain(); domain.setName("testName"); domainRepository.create(domain).blockingGet(); TestObserver<Set<Domain>> testObserver1 = domainRepository.findAll().test(); testObserver1.awaitTerminalEvent(); testObserver1.assertComplete(); testObserver1.assertNoErrors(); testObserver1.assertValue(domains -> domains.size() == 1); }
@Override public Single<Set<Domain>> findAll() { return Observable.fromPublisher(domainsCollection.find()).map(this::convert).collect(HashSet::new, Set::add); }
MongoDomainRepository extends AbstractManagementMongoRepository implements DomainRepository { @Override public Single<Set<Domain>> findAll() { return Observable.fromPublisher(domainsCollection.find()).map(this::convert).collect(HashSet::new, Set::add); } }
MongoDomainRepository extends AbstractManagementMongoRepository implements DomainRepository { @Override public Single<Set<Domain>> findAll() { return Observable.fromPublisher(domainsCollection.find()).map(this::convert).collect(HashSet::new, Set::add); }  }
MongoDomainRepository extends AbstractManagementMongoRepository implements DomainRepository { @Override public Single<Set<Domain>> findAll() { return Observable.fromPublisher(domainsCollection.find()).map(this::convert).collect(HashSet::new, Set::add); }  @PostConstruct void init(); @Override Single<Set<Domain>> findAll(); @Override Maybe<Domain> findById(String id); @Override Single<Set<Domain>> findByIdIn(Collection<String> ids); @Override Flowable<Domain> findAllByEnvironment(String environmentId); @Override Maybe<Domain> findMaster(); @Override Single<Domain> create(Domain item); @Override Single<Domain> update(Domain item); @Override Completable delete(String id); }
MongoDomainRepository extends AbstractManagementMongoRepository implements DomainRepository { @Override public Single<Set<Domain>> findAll() { return Observable.fromPublisher(domainsCollection.find()).map(this::convert).collect(HashSet::new, Set::add); }  @PostConstruct void init(); @Override Single<Set<Domain>> findAll(); @Override Maybe<Domain> findById(String id); @Override Single<Set<Domain>> findByIdIn(Collection<String> ids); @Override Flowable<Domain> findAllByEnvironment(String environmentId); @Override Maybe<Domain> findMaster(); @Override Single<Domain> create(Domain item); @Override Single<Domain> update(Domain item); @Override Completable delete(String id);  }