call.enqueue(
      object : Callback {
        override fun onFailure(
          call: Call,
          e: IOException,
        ) {
          exceptionRef.set(e)
          latch.countDown()
        }

        @Throws(IOException::class)
        override fun onResponse(
          call: Call,
          response: Response,
        ) {
          response.close()

     * @return coded bytes of the tagged object
     * @throws IOException if reading fails or tag mismatch
     */
    public static byte[] readUnparsedTagged(final int expectTag, final int limit, final ASN1InputStream in) throws IOException {
        final int ftag = in.read();
        final int tag = readTagNumber(in, ftag);
        if (tag != expectTag) {
            throw new IOException("Unexpected tag " + tag);
        }

    /**
     * Get the address the service is listening on
     *
     * @return the service address
     * @throws IOException if address cannot be determined
     */
    public InetAddress getAddress() throws IOException {
        if (serverSocket == null) {
            throw new IOException("Service not started");
        }
        return InetAddress.getLocalHost();
    }

    /**

    /**
     * Test method for
     * {@link org.codelibs.core.io.PropertiesUtil#store(Properties, java.io.OutputStream, String)}
     * .
     *
     * @throws IOException
     */
    @Test
    public void testStorePropertiesOutputStreamString() throws IOException {
        final Properties outProperties = new Properties();
        outProperties.setProperty("a", "A");
        final File file = tempFolder.newFile("hoge.properties");

  }

  public void testGetClassPathFromManifest_noClassPath() throws IOException {
    File jarFile = new File("base.jar");
    assertThat(ClassPath.getClassPathFromManifest(jarFile, manifest(""))).isEmpty();
  }

  public void testGetClassPathFromManifest_emptyClassPath() throws IOException {
    File jarFile = new File("base.jar");

    InputStream lin = ByteStreams.limit(bin, 2);

    IOException expected = assertThrows(IOException.class, lin::reset);
    assertThat(expected).hasMessageThat().isEqualTo("Mark not set");
  }

  public void testLimit_markNotSupported() {
    InputStream lin = ByteStreams.limit(new UnmarkableInputStream(), 2);

    IOException expected = assertThrows(IOException.class, lin::reset);

   * independent stream each time it is called.
   *
   * <p>The caller is responsible for ensuring that the returned stream is closed.
   *
   * @throws IOException if an I/O error occurs while opening the stream
   */
  public abstract OutputStream openStream() throws IOException;

  /**
   * Opens a new buffered {@link OutputStream} for writing to this sink. The returned stream is not

  }

  @Throws(IOException::class)
  private fun readPriority(
    handler: Handler,
    length: Int,
    flags: Int,
    streamId: Int,
  ) {
    if (length != 5) throw IOException("TYPE_PRIORITY length: $length != 5")
    if (streamId == 0) throw IOException("TYPE_PRIORITY streamId == 0")
    readPriority(handler, streamId)
  }

  @Throws(IOException::class)
  private fun readPriority(
    handler: Handler,

 */
package okhttp3

import java.io.IOException
import java.net.InetAddress
import java.net.Socket
import javax.net.SocketFactory

/**
 * A [SocketFactory] that delegates calls. Sockets can be configured after creation by
 * overriding [.configureSocket].
 */
open class DelegatingSocketFactory(
  private val delegate: SocketFactory,
) : SocketFactory() {
  @Throws(IOException::class)
  override fun createSocket(): Socket {

     * @param writer a writer object.
     * @param model a model object.
     * @throws IOException java.io.IOException if any.
     */
    public void write(Writer writer, Model model) throws IOException {
        try {
            delegate.write(writer, model.getDelegate());
        } catch (XMLStreamException e) {
            throw new IOException(e);
        }
    } // -- void write( Writer, Model )

    /**
     * Method write.