val response1 = client.newCall(request).execute()
    val in1 = response1.body.source()
    assertThat(in1.readUtf8("I love ".length.toLong())).isEqualTo("I love ")
    in1.skip("puppies but hate ".length.toLong())
    assertThat(in1.readUtf8("spiders".length.toLong())).isEqualTo("spiders")
    assertThat(in1.exhausted()).isTrue()
    in1.close()
    assertThat(cache.writeSuccessCount()).isEqualTo(1)

        outputContains("capabilities: [[capability group='test', name='test', version='1.3'], [capability group='test', name='test2', version='2.3']]")
        // transformed outputs should belong to same component as original
        outputContains("artifacts: [test-1.3.jar.txt (test:test:1.3), test2-2.3.jar.txt (test:test2:2.3)]")
        outputContains("components: [test:test:1.3, test:test2:2.3]")

          <code>
            <![CDATA[
    /**
     * Gets the POM file for the corresponding project (if any).
     *
     * @return The POM file from which this model originated or {@code null} if this model does not belong to a local
     *         project (e.g. describes the metadata of some artifact from the repository).
     */
    @Deprecated
    public java.io.File getPomFile() {

                var bytesWritten: Long = 0
                while (bytesWritten < contentLength) {
                  val byteCount = Math.min(buffer.size.toLong(), contentLength - bytesWritten).toInt()
                  bytesWritten += byteCount.toLong()
                  sink.write(buffer, 0, byteCount)
                }
              }
            },
        ),
      )
    assertContent("", response)

      .build()
  private val callback = RecordingCallback()
  private val cache =
    Cache(
      fileSystem = LoggingFilesystem(fileSystem),
      directory = "/cache".toPath(),
      maxSize = Int.MAX_VALUE.toLong(),
    )

  @BeforeEach
  fun setUp(
    server: MockWebServer,
    @MockWebServerInstance("server2") server2: MockWebServer,
  ) {
    this.server = server
    this.server2 = server2

	nodeName types.NodeName,
	actualStateOfWorld ActualStateOfWorldAttacherUpdater) (volumetypes.GeneratedOperations, error) {
	// volumesPerPlugin maps from a volume plugin to a list of volume specs which belong
	// to this type of plugin
	volumesPerPlugin := make(map[string][]*volume.Spec)
	// volumeSpecMap maps from a volume spec to its unique volumeName which will be used
	// when calling MarkVolumeAsDetached

    /** The key of the message: {item} should be numeric. */
    public static final String CONSTRAINTS_TypeLong_MESSAGE = "{constraints.TypeLong.message}";

    /** The key of the message: {item} should be numeric. */
    public static final String CONSTRAINTS_TypeFloat_MESSAGE = "{constraints.TypeFloat.message}";

        "properties": {
          "apiVersion": {
            "description": "APIVersion is the API group version the resources belong to. In format of \"group/version\". Required.",
            "type": "string"
          },
          "kind": {
            "description": "Kind is the API kind the resources belong to. Required.",
            "type": "string"
          }
        },
        "type": "object",

        "properties": {
          "apiVersion": {
            "description": "APIVersion is the API group version the resources belong to. In format of \"group/version\". Required.",
            "type": "string"
          },
          "kind": {
            "description": "Kind is the API kind the resources belong to. Required.",
            "type": "string"
          }
        },
        "type": "object",

	healDisks := make(map[string]struct{}, len(healing.HealDisks))
	for _, disk := range healing.HealDisks {
		healDisks[disk] = struct{}{}
	}

	// find all disks which belong to each respective endpoints
	for i, disk := range storageInfo.Disks {
		if _, ok := healDisks[disk.Endpoint]; ok {
			storageInfo.Disks[i].Healing = true
		}
	}

	// Marshal API response