public static final field EMPTY Lokhttp3/TrailersSource;
	public abstract fun get ()Lokhttp3/Headers;
	public fun peek ()Lokhttp3/Headers;
}

public final class okhttp3/TrailersSource$Companion {
}

public final class okhttp3/TrailersSource$DefaultImpls {
	public static fun peek (Lokhttp3/TrailersSource;)Lokhttp3/Headers;
}

public abstract interface class okhttp3/WebSocket {

	// Verify it is a regular file, otherwise subsequent Seek is
	// undefined.
	if !st.Mode().IsRegular() {
		file.Close()
		return nil, errIsNotRegular
	}

	if st.Size() < offset+length {
		// Expected size cannot be satisfied for
		// requested offset and length
		file.Close()
		return nil, errFileCorrupt
	}

	if offset > 0 {
		if _, err = file.Seek(offset, io.SeekStart); err != nil {

            } catch (e: IOException) {
              throw RuntimeException(e)
            }
          }
          return result
        }

        override fun peek(): MockResponse = queueDispatcher.peek()

        override fun close() {
          queueDispatcher.close()
        }
      }
    client =
      client
        .newBuilder()
        .proxy(server.proxyAddress)

		r.File = make([]*File, 0, end.directoryRecords)
	}
	r.Comment = end.comment
	rs := io.NewSectionReader(rdr, 0, size)
	if _, err = rs.Seek(r.baseOffset+int64(end.directoryOffset), io.SeekStart); err != nil {
		return err
	}
	buf := bufio.NewReader(rs)

	// The count of files inside a zip is truncated to fit in a uint16.

    return unmodifiableCollectionSubclass(createCollection());
  }

  /**
   * Creates the collection of values for a single key.
   *
   * <p>Collections with weak, soft, or phantom references are not supported. Each call to {@code
   * createCollection} should create a new instance.
   *
   * <p>The returned collection class determines whether duplicate key-value pairs are allowed.
   *

## Version 5.1.0

_2025-07-07_

 *  New: `Response.peekTrailers()`. When we changed `Response.trailers()` to block instead of
    throwing in 5.0.0, we inadvertently removed the ability for callers to peek the trailers
    (by catching the `IllegalStateException` if they weren't available). This new API restores that
    capability.

 *  Fix: Don't crash on `trailers()` if the response doesn't have a body. We broke [Retrofit] users

	public static final field EMPTY Lokhttp3/TrailersSource;
	public abstract fun get ()Lokhttp3/Headers;
	public fun peek ()Lokhttp3/Headers;
}

public final class okhttp3/TrailersSource$Companion {
}

public final class okhttp3/TrailersSource$DefaultImpls {
	public static fun peek (Lokhttp3/TrailersSource;)Lokhttp3/Headers;
}

public abstract interface class okhttp3/WebSocket {

		for _, list := range cfV1.Pools {
			pools = append(pools, poolArgs{
				args:          list,
				setDriveCount: setDriveCount,
			})
		}
	case "v2":
		cf := config.ServerConfig{}
		cfReader.Seek(0, io.SeekStart)
		if err = yaml.Unmarshal(rd, &cf); err != nil {
			return err
		}

		pools = make([]poolArgs, 0, len(cf.Pools))
		for _, list := range cf.Pools {
			driveCount := list.SetDriveCount

pkg io, type Seeker interface { Seek }
pkg io, type Seeker interface, Seek(int64, int) (int64, error)
pkg io, type WriteCloser interface { Close, Write }
pkg io, type WriteCloser interface, Close() error
pkg io, type WriteCloser interface, Write([]uint8) (int, error)
pkg io, type WriteSeeker interface { Seek, Write }
pkg io, type WriteSeeker interface, Seek(int64, int) (int64, error)

		{bucketNames[2], "minio-object", objectNames[1], "", "", 10, listMultipartResults[34], nil, true},
	}

	for i, testCase := range testCases {
		// fmt.Println(i+1, testCase) // uncomment to peek into the test cases.
		actualResult, actualErr := obj.ListMultipartUploads(context.Background(), testCase.bucket, testCase.prefix, testCase.keyMarker, testCase.uploadIDMarker, testCase.delimiter, testCase.maxUploads)