fun zip(destZip: File, srcDir: File) {
        val srcPath = srcDir.toPath()
        Files.walk(srcPath).use { paths ->
            zip(destZip,
                paths.filter { Files.isRegularFile(it, LinkOption.NOFOLLOW_LINKS) }
                    .map { srcPath.relativize(it).toString() to it.toFile() }
                    .toList()
            )
        }
    }

    private

pkg syscall (freebsd-386-cgo), const O_EXLOCK ideal-int
pkg syscall (freebsd-386-cgo), const O_FSYNC ideal-int
pkg syscall (freebsd-386-cgo), const O_NDELAY ideal-int
pkg syscall (freebsd-386-cgo), const O_NOFOLLOW ideal-int
pkg syscall (freebsd-386-cgo), const O_SHLOCK ideal-int
pkg syscall (freebsd-386-cgo), const O_TTY_INIT ideal-int
pkg syscall (freebsd-386-cgo), const PARENB ideal-int

pkg syscall (darwin-386), const O_EXLOCK = 32
pkg syscall (darwin-386), const O_FSYNC = 128
pkg syscall (darwin-386), const O_NDELAY = 4
pkg syscall (darwin-386), const O_NOCTTY = 131072
pkg syscall (darwin-386), const O_NOFOLLOW = 256
pkg syscall (darwin-386), const O_NONBLOCK = 4
pkg syscall (darwin-386), const O_POPUP = 2147483648
pkg syscall (darwin-386), const O_SHLOCK = 16
pkg syscall (darwin-386), const O_SYMLINK = 2097152

Read more about port forwarding here: http://kubernetes.io/docs/user-guide/kubectl/kubectl_port-forward/

You can now access MinIO server on http://localhost:9000. Follow the below steps to connect to MinIO server with mc client:

  1. Download the MinIO mc client - https://min.io/docs/minio/linux/reference/minio-mc.html#quickstart

### Events with Retries and Follow-Ups

OkHttp is resilient and can automatically recover from some connectivity failures. In this case, the `connectFailed()` event is not terminal and not followed by `callFailed()`. Event listeners will receive multiple events of the same type when retries are attempted.

    }
    serverWriter.writeMessageFrame(OPCODE_BINARY, payload.snapshot())

    // Write directly to the unbuffered sink. This ensures it will become single frame.
    assertData("827e") // 'e' == 4-byte follow-up length.
    assertData(format("%04X", payload.completeSegmentByteCount()))
    assertData(payload.readByteString())
  }

  @Test fun serverMessageLengthLong() {

   * OkHttp in the current runtime. Use this to include the OkHttp version in custom `User-Agent`
   * headers.
   *
   * Official OkHttp releases follow [semantic versioning][semver]. Versions with the `-SNAPSHOT`
   * qualifier are not unique and should only be used in development environments. If you create

## Get started

### 1. Prerequisites

- JAVA 1.8 and above installed already and JAVA_HOME points to JAVA 1.8 installation.
- Download WSO2 follow their [installation guide](https://docs.wso2.com/display/IS540/Installation+Guide).

### 2. Configure WSO2

      requestBody.close()
      assertThat(responseBody.readUtf8Line()).isNull()
    }
    body.awaitSuccess()
  }

  /**
   * Duplex calls that have follow-ups are weird. By the time we know there's a follow-up we've
   * already split off another thread to stream the request body. Because we permit at most one
   * exchange at a time we break the request stream out from under that writer.
   */
  @Test

can make. We therefore encourage reporting security issues with the code
contained in this repository.

If you believe you have discovered a security vulnerability, please follow the
guidelines at https://bugcrowd.com/squareopensource


## Verifying Artifacts

We sign our artifacts using this [key][signing_key]:

```