*/
  @Test
  fun largeHeaderValue() {
    val value = CharArray(4096)
    Arrays.fill(value, '!')
    val headerBlock = headerEntries("cookie", String(value))
    hpackWriter!!.writeHeaders(headerBlock)
    bytesIn.writeAll(bytesOut)
    hpackReader!!.readHeaders()
    assertThat(hpackReader!!.headerCount).isEqualTo(0)
    assertThat(hpackReader!!.getAndResetHeaderList()).isEqualTo(headerBlock)
  }

  /**

    assertThat(stream.readBytes.total).isEqualTo(0L)
    assertThat(stream.takeHeaders()).isEqualTo(headersOf("a", "android"))
    val source = stream.source
    val buffer = Buffer()
    buffer.writeAll(source)
    assertThat(source.read(buffer, 1)).isEqualTo(-1)
    assertThat(buffer.size).isEqualTo(150)
    val synStream = peer.takeFrame()
    assertThat(synStream.type).isEqualTo(Http2.TYPE_HEADERS)

	if !s.checkID(p.DiskID) {
		return grid.NewNPErr(errDiskNotFound)
	}

	volume := p.Volume
	filePath := p.FilePath

	return grid.NewNPErr(s.getStorage().WriteAll(context.Background(), volume, filePath, p.Buf))
}

// ReadAllHandler - read all the contents of a file.
func (s *storageRESTServer) ReadAllHandler(p *ReadAllHandlerParams) (*grid.Bytes, *grid.RemoteErr) {

HSPLokio/Buffer;->write(Lokio/Buffer;J)V
HSPLokio/Buffer;->write(Lokio/ByteString;)Lokio/Buffer;
HSPLokio/Buffer;->write([B)Lokio/Buffer;
HSPLokio/Buffer;->write([BII)Lokio/Buffer;
HSPLokio/Buffer;->writeAll(Lokio/Source;)J
HSPLokio/Buffer;->writeByte(I)Lokio/Buffer;
HSPLokio/Buffer;->writeByte(I)Lokio/BufferedSink;
HSPLokio/Buffer;->writeInt(I)Lokio/Buffer;
HSPLokio/Buffer;->writeShort(I)Lokio/Buffer;

	}
	if z.Disable == nil {
		err = en.WriteNil()
		if err != nil {
			return
		}
	} else {
		err = en.WriteBool(*z.Disable)
		if err != nil {
			err = msgp.WrapError(err, "Disable")
			return
		}
	}
	// write "Batch"
	err = en.Append(0xa5, 0x42, 0x61, 0x74, 0x63, 0x68)
	if err != nil {
		return
	}
	if z.Batch == nil {
		err = en.WriteNil()
		if err != nil {
			return
		}

		return
	}
	if z.Update == nil {
		err = en.WriteNil()
		if err != nil {
			return
		}
	} else {
		err = z.Update.EncodeMsg(en)
		if err != nil {
			err = msgp.WrapError(err, "Update")
			return
		}
	}
	// write "f"
	err = en.Append(0xa1, 0x66)
	if err != nil {
		return
	}
	if z.Final == nil {
		err = en.WriteNil()
		if err != nil {
			return
		}
	} else {

        return StreamResponse.asEmptyBody(); // no-op
    }

    private StreamResponse writeNdjsonResponse(final String id, final Consumer<Writer> writeCall) {
        return asStream(id)//
                .header("Pragma", "no-cache")//
                .header("Cache-Control", "no-cache")//
                .header("Expires", "Thu, 01 Dec 1994 16:00:00 GMT")//

    }

    private Path getFessJsonPath() {
        return ResourceUtil.getClassesPath("fess_indices", "fess.json");
    }

    private StreamResponse writeNdjsonResponse(final String id, final Consumer<Writer> writeCall) {
        return asStream(id)//
                .header("Pragma", "no-cache")//
                .header("Cache-Control", "no-cache")//
                .header("Expires", "Thu, 01 Dec 1994 16:00:00 GMT")//

	}
	if z.KeyRotate == nil {
		err = en.WriteNil()
		if err != nil {
			return
		}
	} else {
		err = z.KeyRotate.EncodeMsg(en)
		if err != nil {
			err = msgp.WrapError(err, "KeyRotate")
			return
		}
	}
	// write "Expire"
	err = en.Append(0xa6, 0x45, 0x78, 0x70, 0x69, 0x72, 0x65)
	if err != nil {
		return
	}
	if z.Expire == nil {
		err = en.WriteNil()
		if err != nil {
			return
		}

	}
	if (zb0001Mask & 0x1) == 0 { // if not omitted
		// write "V2Obj"
		err = en.Append(0xa5, 0x56, 0x32, 0x4f, 0x62, 0x6a)
		if err != nil {
			return
		}
		if z.ObjectV2 == nil {
			err = en.WriteNil()
			if err != nil {
				return
			}
		} else {
			// map header, size 1
			// write "DDir"
			err = en.Append(0x81, 0xa4, 0x44, 0x44, 0x69, 0x72)
			if err != nil {
				return
			}