@Test public void testNotFoundById() throws TechnicalException { eventRepository.findById("test").test().assertEmpty(); }
@Override public Maybe<Event> findById(String id) { return Observable.fromPublisher(eventsCollection.find(eq(FIELD_ID, id)).first()).map(this::convert).firstElement(); }
MongoEventRepository extends AbstractManagementMongoRepository implements EventRepository { @Override public Maybe<Event> findById(String id) { return Observable.fromPublisher(eventsCollection.find(eq(FIELD_ID, id)).first()).map(this::convert).firstElement(); } }
MongoEventRepository extends AbstractManagementMongoRepository implements EventRepository { @Override public Maybe<Event> findById(String id) { return Observable.fromPublisher(eventsCollection.find(eq(FIELD_ID, id)).first()).map(this::convert).firstElement(); }  }
MongoEventRepository extends AbstractManagementMongoRepository implements EventRepository { @Override public Maybe<Event> findById(String id) { return Observable.fromPublisher(eventsCollection.find(eq(FIELD_ID, id)).first()).map(this::convert).firstElement(); }  @PostConstruct void init(); @Override Single<List<Event>> findByTimeFrame(long from, long to); @Override Maybe<Event> findById(String id); @Override Single<Event> create(Event item); @Override Single<Event> update(Event item); @Override Completable delete(String id); }
MongoEventRepository extends AbstractManagementMongoRepository implements EventRepository { @Override public Maybe<Event> findById(String id) { return Observable.fromPublisher(eventsCollection.find(eq(FIELD_ID, id)).first()).map(this::convert).firstElement(); }  @PostConstruct void init(); @Override Single<List<Event>> findByTimeFrame(long from, long to); @Override Maybe<Event> findById(String id); @Override Single<Event> create(Event item); @Override Single<Event> update(Event item); @Override Completable delete(String id);  }