com.atlassian.jira.issue.attachment.zip

Class AttachmentZipEntryStreamConsumer

java.lang.Object

com.atlassian.jira.issue.attachment.zip.AttachmentZipEntryStreamConsumer

All Implemented Interfaces:

InputStreamConsumer<io.atlassian.blobstore.client.api.Unit>

public class AttachmentZipEntryStreamConsumer
extends Object
implements InputStreamConsumer<io.atlassian.blobstore.client.api.Unit>

This class implements InputStreamConsumer. It will consume inputStream, which have to provide valid zipStream data and stream content of entry with specified index to provided outputStream.

Since:

6.4

Constructor Summary

Constructors

Constructor and Description
AttachmentZipEntryStreamConsumer(OutputStream outputStream, Consumer<org.apache.commons.compress.archivers.zip.ZipArchiveEntry> onZipEntryExists, int entryIndex) Constructing AttachmentZipEntryStreamConsumer

Method Summary

Modifier and Type	Method and Description
io.atlassian.blobstore.client.api.Unit	withInputStream(InputStream inputStream) This method will consume inputStream, which have to provide valid zipStream data and stream content of entry with specified index to provided outputStream.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

AttachmentZipEntryStreamConsumer

public AttachmentZipEntryStreamConsumer(OutputStream outputStream,
                                        Consumer<org.apache.commons.compress.archivers.zip.ZipArchiveEntry> onZipEntryExists,
                                        int entryIndex)

Constructing AttachmentZipEntryStreamConsumer

Parameters:

outputStream - outputStream where content of zipEntry will be streamed

onZipEntryExists - consumer which will get called before any data will get streamed into outputStream

entryIndex - index of zip entry which content will get streamed to outputStream, counting from 0

Method Detail

withInputStream

public io.atlassian.blobstore.client.api.Unit withInputStream(InputStream inputStream)
                                                       throws IOException,
                                                              ZipEntryNotFoundException

This method will consume inputStream, which have to provide valid zipStream data and stream content of entry with specified index to provided outputStream. Callback Consumer onZipEntryExists method will get called before any bytes gets written to outputStream.

Specified by:

withInputStream in interface InputStreamConsumer<io.atlassian.blobstore.client.api.Unit>

Parameters:

inputStream - has to provide valid zipStream bytes

Returns:

Unit

Throws:

ZipEntryNotFoundException - when entry with given index was not found

IOException