*/
package okhttp3.recipes;

import java.io.IOException;
import okhttp3.Headers;
import okhttp3.OkHttpClient;
import okhttp3.Request;
import okhttp3.Response;

public final class SynchronousGet {
  private final OkHttpClient client = new OkHttpClient();

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

/**
 * An unhashable object to be used in testing as values in our collections.
 *
 * @author Regina O'Dell
 */
@GwtCompatible
public class UnhashableObject implements Comparable<UnhashableObject> {
  private final int value;

  public UnhashableObject(int value) {
    this.value = value;
  }

  @Override
  public boolean equals(@Nullable Object object) {
    if (object instanceof UnhashableObject) {

/**
 * The Exception class throw by the {@link Prompter} service.
 *
 * @since 4.0.0
 */
@Experimental
public class PrompterException extends MavenException {

    @Serial
    private static final long serialVersionUID = -3505070928479515081L;

    public PrompterException(String message) {
        super(message);
    }

    /**
     * @param message the message to give

            password("env.ORG_GRADLE_PROJECT_sdkmanToken", "%sdkmanToken%")
            param("env.JAVA_HOME", javaHome(BuildToolBuildJvm, Os.LINUX))
            // https://github.com/gradle/gradle-private/issues/4504
            param("env.JDK8", javaHome(OpenJdk8, Os.LINUX))
            param("env.JDK11", javaHome(OpenJdk11, Os.LINUX))
            param("env.JDK17", javaHome(OpenJdk17, Os.LINUX))

 * It extends CrawlerSystemException and provides constructors to create instances with a message and/or a cause.
 *
 */
public class RobotsTxtException extends CrawlerSystemException {

    private static final long serialVersionUID = 1L;

    /**
     * Constructs a new RobotsTxtException with the specified detail message and cause.
     * @param message the detail message
     * @param cause the cause of the exception

 *
 * @author Mike Ward
 */
@GwtCompatible
@NullMarked
public class ImmutableSetMultimapTest extends TestCase {
  @J2ktIncompatible
  @AndroidIncompatible // test-suite builders
  private static final class ImmutableSetMultimapGenerator extends TestStringSetMultimapGenerator {
    @Override
    protected SetMultimap<String, String> create(Entry<String, String>[] entries) {

import org.codelibs.fess.helper.IntervalControlHelper.IntervalRule;
import org.codelibs.fess.unit.UnitFessTestCase;

public class IntervalControlHelperTest extends UnitFessTestCase {

    private IntervalControlHelper intervalControlHelper;

    @Override
    public void setUp() throws Exception {
        super.setUp();
        intervalControlHelper = new IntervalControlHelper();
    }

                return false;
            }
        });
        sambaHelper.init();

        assertEquals("1test user", sambaHelper.getAccountId(USER_SID));

    }

    private static final SID USER_SID = new SID() {

        @Override
        public SID getDomainSid() {
            return null;
        }

        @Override
        public int getRid() {
            return 0;

import jcifs.dcerpc.ndr.NdrBuffer;
import jcifs.dcerpc.ndr.NdrException;

/**
 * Test class for srvsvc.java classes
 */
class srvsvcTest {

    @Mock
    private NdrBuffer mockNdrBuffer;

    @Mock
    private NdrBuffer mockDeferredBuffer;

    @BeforeEach
    void setUp() {
        MockitoAnnotations.openMocks(this);
        // Set the deferred field directly since it's a public field, not a method

import okio.BufferedSink
import org.junit.jupiter.api.Assertions.assertTrue

/** A duplex request body that keeps the provided sinks so they can be written to later.  */
class AsyncRequestBody : RequestBody() {
  private val requestBodySinks: BlockingQueue<BufferedSink> = LinkedBlockingQueue()

  override fun contentType(): MediaType? = null

  override fun writeTo(sink: BufferedSink) {
    requestBodySinks.add(sink)
  }