if (firstUpdate) {
              firstUpdate = false
              if (contentLength == -1L) {
                println("content-length: unknown")
              } else {
                println("content-length: $contentLength")
              }
            }
            println(bytesWritten)
            if (contentLength != -1L) {
              println("${100 * bytesWritten / contentLength}% done")
            }
          }

            } ?: return
          }
        } catch (thrown: Throwable) {
          // A task failed. Update execution state and re-throw the exception.
          withLock {
            afterRun(task, -1L, false)
          }
          if (thrown is InterruptedException) {
            Thread.currentThread().interrupt()
          } else {
            throw thrown
          }
        } finally {

        }

        in 18..19 -> {
          val retryMs = source.readRetryMs()
          if (retryMs != -1L) {
            callback.onRetryChange(retryMs)
          }
        }

        -1 -> {
          val lineEnd = source.indexOfElement(CRLF)
          if (lineEnd != -1L) {
            // Skip the line and newline
            source.skip(lineEnd)
            source.select(options)
          } else {

        generator.setCommandTimeout(-1L);
        assertTrue(true);

        // Test very large timeout
        generator.setCommandTimeout(Long.MAX_VALUE);
        assertTrue(true);

        // Test destroy timeout
        generator.setCommandDestroyTimeout(0L);
        assertTrue(true);

        generator.setCommandDestroyTimeout(-1L);
        assertTrue(true);

                  firstUpdate = false
                  if (contentLength == -1L) {
                    println("content-length: unknown")
                  } else {
                    println("content-length: $contentLength")
                  }
                }
                println(bytesWritten)
                if (contentLength != -1L) {
                  println("${100 * bytesWritten / contentLength}% done")