ZipArchiveOutputStream outStream = new ZipArchiveOutputStream(destination);
        try {
            outStream.setUseZip64(zip64Mode);
            outStream.setMethod(entryCompressionMethod);
            return outStream;
        } catch (Exception e) {
            IoActions.closeQuietly(outStream);

        object.getSize() == fileContents.length()
        object.getEtag() ==~ /\w{32}/
        ByteArrayOutputStream outStream = new ByteArrayOutputStream()
        IOUtils.copyLarge(gcsClient.getResourceStream(uri), outStream)
        outStream.toString() == fileContents

        when:
        server.stubListFile(temporaryFolder.testDirectory, bucketName)

        then:

func (ow *realWatcher) Start(ref *v1.ObjectReference) error {
	outStream := make(chan *oomparser.OomInstance, 10)
	go ow.oomStreamer.StreamOoms(outStream)

	go func() {
		defer runtime.HandleCrash()

		for event := range outStream {
			if event.VictimContainerName == recordEventContainerName {
				klog.V(1).InfoS("Got sys oom event", "event", event)

        return source.open();
    }

    @Override
    public void writeTo(OutputStream outstream) throws IOException {
        InputStream content = getContent();
        try {
            IOUtils.copyLarge(content, outstream);
        } finally {
            IoActions.closeQuietly(content);
        }
    }

    @Override
    public boolean isStreaming() {

	"github.com/stretchr/testify/assert"
)

type fakeStreamer struct {
	oomInstancesToStream []*oomparser.OomInstance
}

func (fs *fakeStreamer) StreamOoms(outStream chan<- *oomparser.OomInstance) {
	for _, oomInstance := range fs.oomInstancesToStream {
		outStream <- oomInstance
	}
}

// TestWatcherRecordsEventsForOomEvents ensures that our OomInstances coming
// from `StreamOoms` are translated into events in our recorder.

            object.metadata.getContentLength() == fileContents.length()
            object.metadata.getETag() ==~ /\w{32}/
            ByteArrayOutputStream outStream = new ByteArrayOutputStream()
            IOUtils.copyLarge(object.getObjectContent(), outStream);
            outStream.toString() == fileContents
        } as Action)

        when:
        server.stubListFile(temporaryFolder.testDirectory, bucketName)

        then:

                throw new UnsupportedOperationException();
            }

            @Override
            public void writeTo(OutputStream outstream) throws IOException {
                writer.writeTo(outstream);
            }

            @Override
            public boolean isStreaming() {
                return false;
            }
        });

            }
        }

        try {
            final PrintStream originalOutStream = System.out;
            final ByteArrayOutputStream outStream = new ByteArrayOutputStream();
            System.setOut(new PrintStream(outStream, true));
            final PrintStream originalErrStream = System.err;
            final ByteArrayOutputStream errStream = new ByteArrayOutputStream();