@Test public void testFindListOfQueryParts() throws InterruptedException, ExecutionException { List<Sender> results = service.find(Map.of("column", "value1")).get(); assertEquals(1, results.size()); }
public CompletableFuture<List<Sender>> find(Map<String, String> searchQuery) { AsyncSearch searchAsync = new AsyncSearch(searchQuery, mainDatasource); return searchAsync.runSearchAsync() .thenApply(res -> StreamSupport.stream(res.spliterator(), false).map(Sender::new).collect(Collectors.toList())); }
SenderService implements XPALProvider { public CompletableFuture<List<Sender>> find(Map<String, String> searchQuery) { AsyncSearch searchAsync = new AsyncSearch(searchQuery, mainDatasource); return searchAsync.runSearchAsync() .thenApply(res -> StreamSupport.stream(res.spliterator(), false).map(Sender::new).collect(Collectors.toList())); } }
SenderService implements XPALProvider { public CompletableFuture<List<Sender>> find(Map<String, String> searchQuery) { AsyncSearch searchAsync = new AsyncSearch(searchQuery, mainDatasource); return searchAsync.runSearchAsync() .thenApply(res -> StreamSupport.stream(res.spliterator(), false).map(Sender::new).collect(Collectors.toList())); } SenderService(Datasource mainDatasource, ColumnTransformer columnTransformer,
      SenderCache cache, String overrideFragDbSpalte); }
SenderService implements XPALProvider { public CompletableFuture<List<Sender>> find(Map<String, String> searchQuery) { AsyncSearch searchAsync = new AsyncSearch(searchQuery, mainDatasource); return searchAsync.runSearchAsync() .thenApply(res -> StreamSupport.stream(res.spliterator(), false).map(Sender::new).collect(Collectors.toList())); } SenderService(Datasource mainDatasource, ColumnTransformer columnTransformer,
      SenderCache cache, String overrideFragDbSpalte); static SenderService getInstance(); @SuppressWarnings("java:S2629") long searchDefaultSender(); @Override String getCurrentSender(); void addPALChangeEventListener(XPALChangeEventListener listener); void removePALChangeEventListener(XPALChangeEventListener listener); @Override String[] getPALEntries(); void selectSender(String senderName, int idx); Map<String, String> getCurrentSenderValues(); String getCurrentSenderValue(String column); ConfigThingy getCurrentOverrideFragMap(); void showManageSenderListDialog(); void select(Sender sender); Sender createNewSender(); List<Sender> getSenderListSorted(String column); List<String> getSchema(); CompletableFuture<List<Sender>> find(Map<String, String> searchQuery); }
SenderService implements XPALProvider { public CompletableFuture<List<Sender>> find(Map<String, String> searchQuery) { AsyncSearch searchAsync = new AsyncSearch(searchQuery, mainDatasource); return searchAsync.runSearchAsync() .thenApply(res -> StreamSupport.stream(res.spliterator(), false).map(Sender::new).collect(Collectors.toList())); } SenderService(Datasource mainDatasource, ColumnTransformer columnTransformer,
      SenderCache cache, String overrideFragDbSpalte); static SenderService getInstance(); @SuppressWarnings("java:S2629") long searchDefaultSender(); @Override String getCurrentSender(); void addPALChangeEventListener(XPALChangeEventListener listener); void removePALChangeEventListener(XPALChangeEventListener listener); @Override String[] getPALEntries(); void selectSender(String senderName, int idx); Map<String, String> getCurrentSenderValues(); String getCurrentSenderValue(String column); ConfigThingy getCurrentOverrideFragMap(); void showManageSenderListDialog(); void select(Sender sender); Sender createNewSender(); List<Sender> getSenderListSorted(String column); List<String> getSchema(); CompletableFuture<List<Sender>> find(Map<String, String> searchQuery); static final String OVERRIDE_FRAG_DB_SPALTE; static final String SENDER_KEY_SEPARATOR; }