org.codehaus.plexus.archiver.zip

Class DeferredScatterOutputStream

java.lang.Object

org.codehaus.plexus.archiver.zip.DeferredScatterOutputStream

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, org.apache.commons.compress.parallel.ScatterGatherBackingStore

public class DeferredScatterOutputStream
extends java.lang.Object
implements org.apache.commons.compress.parallel.ScatterGatherBackingStore

Field Summary

Fields

Modifier and Type	Field and Description
private OffloadingOutputStream	dfos

Constructor Summary

Constructors

Constructor and Description
DeferredScatterOutputStream(int threshold)

Method Summary

Modifier and Type	Method and Description
void	close()
void	closeForWriting()
java.io.InputStream	getInputStream()
void	writeOut(byte[] data, int offset, int length)

Methods inherited from class java.lang.Object

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

Field Detail

dfos

private final OffloadingOutputStream dfos

Constructor Detail

DeferredScatterOutputStream

public DeferredScatterOutputStream(int threshold)

Method Detail

getInputStream

public java.io.InputStream getInputStream()
                                   throws java.io.IOException

Specified by:

getInputStream in interface org.apache.commons.compress.parallel.ScatterGatherBackingStore

Throws:

java.io.IOException

writeOut

public void writeOut(byte[] data,
                     int offset,
                     int length)
              throws java.io.IOException

Specified by:

writeOut in interface org.apache.commons.compress.parallel.ScatterGatherBackingStore

Throws:

java.io.IOException

closeForWriting

public void closeForWriting()
                     throws java.io.IOException

Specified by:

closeForWriting in interface org.apache.commons.compress.parallel.ScatterGatherBackingStore

Throws:

java.io.IOException

close

public void close()
           throws java.io.IOException

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable

Throws:

java.io.IOException