private static final String RETURN_VALUE = "abc";

  private TimeLimiter timeLimiter;

  @Override
  protected void setUp() throws Exception {
    super.setUp();
    timeLimiter = new FakeTimeLimiter();
  }

  public void testCallWithTimeout_propagatesReturnValue() throws Exception {
    String result =
        timeLimiter.callWithTimeout(Callables.returning(RETURN_VALUE), DELAY_MS, MILLISECONDS);

        return Map.of();
    }

    public static Builder builder() {
        return new Builder();
    }

    public static class Builder {
        private final Map<Class<?>, Object> components = new HashMap<>();

        public ProtoLookup build() {
            return new ProtoLookup(components);
        }

        public <T> Builder addMapping(Class<T> type, T component) {

            final int errorCode = in.read() & 0xFF;
            close();
            throw new NbtException(NbtException.ERR_SSN_SRVC, errorCode);
        case -1:
            throw new NbtException(NbtException.ERR_SSN_SRVC, NbtException.CONNECTION_REFUSED);
        default:
            close();
            throw new NbtException(NbtException.ERR_SSN_SRVC, 0);
        }
    }

    @Override

    void customOptions_arePropagated() {
        // Arrange
        Map<String, Object> opts = new HashMap<>();
        opts.put("useKeyTab", "true");
        opts.put("storeKey", "true");
        opts.put("principal", "******@****.***");
        StaticJAASConfiguration cfg = new StaticJAASConfiguration(opts);

        // Act
        AppConfigurationEntry[] entries = cfg.getAppConfigurationEntry("any");

        BeanExpressionEvaluator evaluator = new BeanExpressionEvaluator(request);

        ObjectWithFieldsConverter converter = new EnhancedConfigurationConverter();

        try {
            converter.processConfiguration(
                    converterLookup, request.getBean(), classLoader, plexusConfig, evaluator, null);
        } catch (ComponentConfigurationException e) {
            throw new BeanConfigurationException(e.getMessage(), e);

                    throw new DictionaryException("Failed to update " + dictFile.getPath());
                }
            } catch (final IOException e) {
                throw new DictionaryException("Failed to update " + dictFile.getPath(), e);
            }

        }).orElse(() -> {
            throw new DictionaryException(dictFile.getPath() + " does not exist.");
        });
    }

      () -> {
        MILLISECONDS.sleep(DELAY_MS);
        throw new SampleException();
      };
  private static final Runnable GOOD_RUNNABLE =
      () -> {
        try {
          MILLISECONDS.sleep(DELAY_MS);
        } catch (InterruptedException e) {
          throw new RuntimeException(e);
        }
      };
  private static final Runnable BAD_RUNNABLE =
      () -> {

 *
 * @author mike nonemacher
 */
@GwtCompatible
final class TestingRemovalListeners {

  /** Returns a new no-op {@code RemovalListener}. */
  static <K, V> NullRemovalListener<K, V> nullRemovalListener() {
    return new NullRemovalListener<>();
  }

  /** Type-inferring factory method for creating a {@link QueuingRemovalListener}. */
  @J2ktIncompatible

     */
    public static FileInputStream create(final File file) {
        assertArgumentNotNull("file", file);

        try {
            return new FileInputStream(file);
        } catch (final IOException e) {
            throw new IORuntimeException(e);
        }
    }

    /**
     * Gets a byte array from an {@link InputStream}.
     * <p>
     * The input stream is not closed.
     * </p>

            throws IOException {
        this.handle = handle;
        final MsrpcSamrOpenDomain rpc = new MsrpcSamrOpenDomain(policyHandle, access, sid, this);
        handle.sendrecv(rpc);
        if (rpc.retval != 0) {
            throw new SmbException(rpc.retval, false);
        }
        this.opened = true;
    }

    @Override