code: @Override
    @SuppressWarnings("checkstyle:illegalcatch") // Catch throwable to feed it to error handler
    public void close() {
  
      LOG.entering(CLASS_NAME, "close");
  
      try {
        this.clock.close();
      } catch (final Throwable ex) {
        LOG.log(Level.SEVERE, "Error while closing the clock", ex);
        try {
          this.errorHandler.onNext(ex);
        } catch (final Throwable exHandling) {
          LOG.log(Level.SEVERE, "Error while handling the exception " + ex, exHandling);
        }
      } finally {
        try {
          this.errorHandler.close();
        } catch (final Throwable ex) {
          LOG.log(Level.SEVERE, "Error while closing the error handler", ex);
        }
      }
  
      LOG.exiting(CLASS_NAME, "close");
    }
docs: Close and cleanup the environment.
  Invoke .close() on all closeable members (clock and error handler).