ElasticsearchRestClient implements ElasticsearchClient { @Override public void schedule(Runnable task) { task.run(); }  @Override Map<String, IndexMapping> getIndexMappings(String indexExpression); @Override ElasticsearchResponse search(ElasticsearchRequest request); @Override void cleanup(ElasticsearchRequest request); @Override void schedule(Runnable task);  }
@Test void schedule() { AtomicBoolean isRun = new AtomicBoolean(false); client.schedule( () -> { isRun.set(true); }); assertTrue(isRun.get()); }