@Test public void testFindAll() throws TechnicalException { Tag tag = new Tag(); tag.setName("testName"); tag.setDescription("Description"); tag.setOrganizationId(ORGANIZATION_ID); tagRepository.create(tag).blockingGet(); TestSubscriber<Tag> testObserver1 = tagRepository.findAll(ORGANIZATION_ID).test(); testObserver1.awaitTerminalEvent(); testObserver1.assertComplete(); testObserver1.assertNoErrors(); testObserver1.assertValueCount(1); }
@Override public Flowable<Tag> findAll(String organizationId) { return Flowable.fromPublisher(tagsCollection.find(eq("organizationId", organizationId))).map(this::convert); }
MongoTagRepository extends AbstractManagementMongoRepository implements TagRepository { @Override public Flowable<Tag> findAll(String organizationId) { return Flowable.fromPublisher(tagsCollection.find(eq("organizationId", organizationId))).map(this::convert); } }
MongoTagRepository extends AbstractManagementMongoRepository implements TagRepository { @Override public Flowable<Tag> findAll(String organizationId) { return Flowable.fromPublisher(tagsCollection.find(eq("organizationId", organizationId))).map(this::convert); }  }
MongoTagRepository extends AbstractManagementMongoRepository implements TagRepository { @Override public Flowable<Tag> findAll(String organizationId) { return Flowable.fromPublisher(tagsCollection.find(eq("organizationId", organizationId))).map(this::convert); }  @PostConstruct void init(); @Override Maybe<Tag> findById(String id, String organizationId); @Override Maybe<Tag> findById(String id); @Override Flowable<Tag> findAll(String organizationId); @Override Single<Tag> create(Tag item); @Override Single<Tag> update(Tag item); @Override Completable delete(String id); }
MongoTagRepository extends AbstractManagementMongoRepository implements TagRepository { @Override public Flowable<Tag> findAll(String organizationId) { return Flowable.fromPublisher(tagsCollection.find(eq("organizationId", organizationId))).map(this::convert); }  @PostConstruct void init(); @Override Maybe<Tag> findById(String id, String organizationId); @Override Maybe<Tag> findById(String id); @Override Flowable<Tag> findAll(String organizationId); @Override Single<Tag> create(Tag item); @Override Single<Tag> update(Tag item); @Override Completable delete(String id);  }