public class CancelCall {
  private final ScheduledExecutorService executor = Executors.newScheduledThreadPool(1);
  private final OkHttpClient client = new OkHttpClient();

  public void run() throws Exception {
    Request request = new Request.Builder()
        .url("http://httpbin.org/delay/2") // This URL is served with a 2 second delay.
        .build();

    final long startNanos = System.nanoTime();

     * @return A new {@link SynonymFile} associated with the dictionary manager.
     */
    @Override
    protected DictionaryFile<? extends DictionaryItem> newDictionaryFile(final String id, final String path, final Date timestamp) {
        return new SynonymFile(id, path, timestamp).manager(dictionaryManager);
    }

    /**
     * The logger for this class.
     */
    protected static final Logger logger = Logger.getLogger(ContentCache.class.getName());

    /**
     * A byte array that holds the cached content data.
     */
    private final byte[] data;

    /**
     * The file that is used to cache the content.
     */
    private final File file;

    /**
     * Constructs a ContentCache with the given byte array data.

  }

  /** Tests a single interaction against a method. */
  private static final class InteractionTester<T> extends AbstractInvocationHandler {

    private final Class<T> interfaceType;
    private final Method method;
    private final @Nullable Object[] passedArgs;
    private final @Nullable Object returnValue;
    private final AtomicInteger called = new AtomicInteger();

     */
    @Test
    void testMsrpcSamrConnect4() {
        // Given
        final String server = "test-server";
        final int access = 1;

        // When
        final MsrpcSamrConnect4 request = new MsrpcSamrConnect4(server, access, this.policyHandle);

        // Then
        assertEquals(0, request.getPtype());

    }

    // Test configuration for JSON response
    public void test_configurationSettings() {
        ComponentUtil.setFessConfig(new FessConfig.SimpleImpl() {
            private static final long serialVersionUID = 1L;

            @Override
            public String getApiJsonResponseExceptionIncluded() {
                return "false";
            }
        });

/**
 * ArtifactDoesNotExistException
 */
@Deprecated
public class ArtifactDoesNotExistException extends Exception {
    public ArtifactDoesNotExistException(final String message) {
        super(message);
    }

    public ArtifactDoesNotExistException(final String message, final Throwable cause) {
        super(message, cause);
    }

public class DirectoryLeaseManager {

    private static final Logger log = LoggerFactory.getLogger(DirectoryLeaseManager.class);

    private final CIFSContext context;
    private final LeaseManager baseLeaseManager;
    private final ConcurrentHashMap<String, DirectoryCacheEntry> directoryCache;
    private final ConcurrentHashMap<Smb2LeaseKey, String> leaseToPath;
    private final ScheduledExecutorService scheduler;

    }

    public void test_multipleInstancesHaveIndependentSettings() {
        final SuppressErrorReportValve valve1 = new SuppressErrorReportValve();
        final SuppressErrorReportValve valve2 = new SuppressErrorReportValve();

        valve1.setShowReport(true);
        valve1.setShowServerInfo(true);

        // valve2 should still have default values

import okio.BufferedSource;
import okio.ForwardingSource;
import okio.Okio;
import okio.Source;

public final class Progress {

  public void run() throws Exception {
    Request request = new Request.Builder()
        .url("https://publicobject.com/helloworld.txt")
        .build();

    final ProgressListener progressListener = new ProgressListener() {
      boolean firstUpdate = true;