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