test.java

protected void callReader(boolean onClientThread) {
      final Runnable localReaderCaller = this.readerCaller;
      if (readerCaller != null) {
        if (onClientThread) {
         readerCaller.run();
       } else {
         getClientsThreadExecutor().execute(()->{
           if(localReaderCaller == readerCaller) {
             readerCaller.run();
           }
           });
       }
      }
    }