@Throws(IOException::class)
  override fun shutdownInput() {
    delegate!!.shutdownInput()
  }

  @Throws(IOException::class)
  override fun shutdownOutput() {
    delegate!!.shutdownOutput()
  }

  override fun getSupportedCipherSuites(): Array<String> {
    return delegate!!.supportedCipherSuites
  }

  override fun getEnabledCipherSuites(): Array<String> {

      if (response.socketPolicy === DisconnectAfterRequest) {
        socket.close()
        return false
      }
      if (response.socketPolicy === HalfCloseAfterRequest) {
        socket.shutdownOutput()
        return false
      }
      if (response.socketPolicy === NoResponse) {
        // This read should block until the socket is closed. (Because nobody is writing.)
        if (source.exhausted()) return false

                }
                finally {
                    iter.remove();
                }
            }

            if ( this.socket != null ) {
                this.socket.shutdownOutput();
                this.out.close();
                this.in.close();
                this.socket.close();
                log.trace("Socket closed");
            }
            else {

    val connection =
      Http2Connection.Builder(true, TaskRunner.INSTANCE)
        .socket(socket)
        .pushObserver(IGNORE)
        .build()
    connection.start(sendConnectionPreface = false)
    socket.shutdownOutput()
    assertFailsWith<IOException> {
      connection.newStream(headerEntries("a", longString), false)
    }
    assertFailsWith<IOException> {
      connection.newStream(headerEntries("b", longString), false)