assertFailsWith<ConnectionShutdownException> {
      connection.newStream(headerEntries("b", "banana"), false)
    }
    val sink = stream.sink.buffer()
    assertFailsWith<IOException> {
      sink.writeByte(0)
      sink.flush()
    }.also { expected ->
      assertThat(expected.message).isEqualTo("stream finished")
    }
    assertFailsWith<IOException> {
      stream.source.read(Buffer(), 1)

					if i == len(in) {
						break
					}
				}
				if len(old) == 0 {
					_, length := utf8.DecodeRune(in[i:])
					out.Write(in[i : i+length])
					i += length
				} else {
					out.WriteByte(in[i])
					i++
				}
			}
			if len(old) == 0 && n != 0 {
				out.Write(new)
			}
			return out.Bytes()
		}

        indexFile.deleteOnExit();
        FileUtil.writeBytes(indexFile.getAbsolutePath(), content.getBytes("UTF-8"));

        for (int i = 1; i <= 10; i++) {
            final File file = new File(dir, "file" + count + "-" + i + ".html");
            file.deleteOnExit();
            FileUtil.writeBytes(file.getAbsolutePath(), content.getBytes("UTF-8"));

        }
        File file;
        try {
            file = File.createTempFile("script", extention);
            file.deleteOnExit();
            FileUtil.writeBytes(file.getAbsolutePath(), content.getBytes());
            return file;
        } catch (final IOException e) {
            throw new IORuntimeException(e);
        }
    }

        assertEquals(resultFile, file);
        FileUtil.writeBytes(file.getAbsolutePath(), "abc".getBytes());

        path = "foo1/hoge.html";
        file = fileTransformer.createFile(path);
        resultFile = new File(fileTransformer.baseDir, path);
        assertEquals(resultFile, file);
        FileUtil.writeBytes(file.getAbsolutePath(), "abc".getBytes());

        path = "foo1/foo2/hoge.html";

        indexFile.deleteOnExit();
        FileUtil.writeBytes(indexFile.getAbsolutePath(), content.getBytes("UTF-8"));

        for (int i = 1; i <= 10; i++) {
            final File file = new File(dir, "file" + count + "-" + i + ".html");
            file.deleteOnExit();
            FileUtil.writeBytes(file.getAbsolutePath(), content.getBytes("UTF-8"));

            writeParams.setAccessible(true);
            writeParams.invoke(cancel, dst, 0);

            Method writeBytes = SmbComNtCancel.class.getDeclaredMethod("writeBytesWireFormat", byte[].class, int.class);
            writeBytes.setAccessible(true);
            writeBytes.invoke(cancel, dst, 0);

            // Then - array should remain unchanged
            assertArrayEquals(originalDst, dst);
        }

        indexFile.deleteOnExit();
        FileUtil.writeBytes(indexFile.getAbsolutePath(), content.getBytes("UTF-8"));

        for (int i = 1; i <= 10; i++) {
            final File file = new File(dir, "file" + count + "-" + i + ".html");
            file.deleteOnExit();
            FileUtil.writeBytes(file.getAbsolutePath(), content.getBytes("UTF-8"));

	if err != nil {
		return
	}
	err = en.WriteBytes(z.PolicyConfigJSON)
	if err != nil {
		err = msgp.WrapError(err, "PolicyConfigJSON")
		return
	}
	// write "NotificationConfigXML"
	err = en.Append(0xb5, 0x4e, 0x6f, 0x74, 0x69, 0x66, 0x69, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x58, 0x4d, 0x4c)
	if err != nil {
		return
	}
	err = en.WriteBytes(z.NotificationConfigXML)
	if err != nil {

		err = en.Append(0xa2, 0x49, 0x44)
		if err != nil {
			return
		}
		err = en.WriteBytes((z.VersionID)[:])
		if err != nil {
			err = msgp.WrapError(err, "VersionID")
			return
		}
		// write "DDir"
		err = en.Append(0xa4, 0x44, 0x44, 0x69, 0x72)
		if err != nil {
			return
		}
		err = en.WriteBytes((z.DataDir)[:])
		if err != nil {
			err = msgp.WrapError(err, "DataDir")
			return