本文整理了Java中org.apache.commons.compress.archivers.zip.ZipArchiveEntryRequest类的一些代码示例，展示了ZipArchiveEntryRequest类的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。ZipArchiveEntryRequest类的具体详情如下：
包路径：org.apache.commons.compress.archivers.zip.ZipArchiveEntryRequest
类名称：ZipArchiveEntryRequest

ZipArchiveEntryRequest介绍

[英]A Thread-safe representation of a ZipArchiveEntry that is used to add entries to parallel archives.
[中]ZipArchiveEntry的线程安全表示，用于将条目添加到并行存档。

代码示例

代码示例来源：origin: org.apache.commons/commons-compress

throw new IllegalArgumentException("Method must be set on zipArchiveEntry: " + zipArchiveEntry);
final ZipArchiveEntryRequest zipArchiveEntryRequest = createZipArchiveEntryRequest(zipArchiveEntry, source);
return new Callable<Object>() {
  @Override

代码示例来源：origin: org.apache.commons/commons-compress

/**
 * Create a ZipArchiveEntryRequest
 * @param zipArchiveEntry The entry to use
 * @param payloadSupplier The payload that will be added to the zip entry.
 * @return The newly created request
 */
public static ZipArchiveEntryRequest createZipArchiveEntryRequest(final ZipArchiveEntry zipArchiveEntry, final InputStreamSupplier payloadSupplier) {
  return new ZipArchiveEntryRequest(zipArchiveEntry, payloadSupplier);
}

代码示例来源：origin: org.apache.commons/commons-compress

/**
 * Add an archive entry to this scatter stream.
 *
 * @param zipArchiveEntryRequest The entry to write.
 * @throws IOException    If writing fails
 */
public void addArchiveEntry(final ZipArchiveEntryRequest zipArchiveEntryRequest) throws IOException {
  try (final InputStream payloadStream = zipArchiveEntryRequest.getPayloadStream()) {
    streamCompressor.deflate(payloadStream, zipArchiveEntryRequest.getMethod());
  }
  items.add(new CompressedEntry(zipArchiveEntryRequest, streamCompressor.getCrc32(),
                 streamCompressor.getBytesWrittenForLastEntry(), streamCompressor.getBytesRead()));
}

代码示例来源：origin: org.apache.commons/commons-compress

/**
   * Update the original {@link ZipArchiveEntry} with sizes/crc
   * Do not use this methods from threads that did not create the instance itself !
   * @return the zipArchiveEntry that is basis for this request
   */
  public ZipArchiveEntry transferToArchiveEntry(){
    final ZipArchiveEntry entry = zipArchiveEntryRequest.getZipArchiveEntry();
    entry.setCompressedSize(compressedSize);
    entry.setSize(size);
    entry.setCrc(crc);
    entry.setMethod(zipArchiveEntryRequest.getMethod());
    return entry;
  }
}

代码示例来源：origin: com.impetus.fabric/fabric-jdbc-driver-shaded

/**
   * Update the original {@link ZipArchiveEntry} with sizes/crc
   * Do not use this methods from threads that did not create the instance itself !
   * @return the zipArchiveEntry that is basis for this request
   */
  public ZipArchiveEntry transferToArchiveEntry(){
    final ZipArchiveEntry entry = zipArchiveEntryRequest.getZipArchiveEntry();
    entry.setCompressedSize(compressedSize);
    entry.setSize(size);
    entry.setCrc(crc);
    entry.setMethod(zipArchiveEntryRequest.getMethod());
    return entry;
  }
}

代码示例来源：origin: org.codehaus.plexus/plexus-archiver

private ZipArchiveEntryRequest createEntry( final ZipArchiveEntry zipArchiveEntry,
                      final InputStreamSupplier inputStreamSupplier ) throws IOException
{
  // if we re-compress the zip files there is no need to look at the input stream
  if ( compressAddedZips )
  {
    return createZipArchiveEntryRequest( zipArchiveEntry, inputStreamSupplier );
  }
  // otherwise we should inspect the first four bites to see if the input stream is zip file or not
  InputStream is = inputStreamSupplier.get();
  byte[] header = new byte[4];
  try
  {
    int read = is.read( header );
    int compressionMethod = zipArchiveEntry.getMethod();
    if ( isZipHeader( header ) ) {
      compressionMethod = ZipEntry.STORED;
    }
    zipArchiveEntry.setMethod( compressionMethod );
    return createZipArchiveEntryRequest( zipArchiveEntry, prependBytesToStream( header, read, is ) );
  }
  catch ( IOException e )
  {
    IOUtil.close( is );
    throw e;
  }
}

代码示例来源：origin: com.impetus.fabric/fabric-jdbc-driver-shaded

/**
 * Add an archive entry to this scatter stream.
 *
 * @param zipArchiveEntryRequest The entry to write.
 * @throws IOException    If writing fails
 */
public void addArchiveEntry(final ZipArchiveEntryRequest zipArchiveEntryRequest) throws IOException {
  try (final InputStream payloadStream = zipArchiveEntryRequest.getPayloadStream()) {
    streamCompressor.deflate(payloadStream, zipArchiveEntryRequest.getMethod());
  }
  items.add(new CompressedEntry(zipArchiveEntryRequest, streamCompressor.getCrc32(),
                 streamCompressor.getBytesWrittenForLastEntry(), streamCompressor.getBytesRead()));
}

代码示例来源：origin: com.impetus.fabric/fabric-jdbc-driver-shaded

/**
 * Create a ZipArchiveEntryRequest
 * @param zipArchiveEntry The entry to use
 * @param payloadSupplier The payload that will be added to the zip entry.
 * @return The newly created request
 */
public static ZipArchiveEntryRequest createZipArchiveEntryRequest(final ZipArchiveEntry zipArchiveEntry, final InputStreamSupplier payloadSupplier) {
  return new ZipArchiveEntryRequest(zipArchiveEntry, payloadSupplier);
}

代码示例来源：origin: org.codehaus.plexus/plexus-archiver

directories.addArchiveEntry( createZipArchiveEntryRequest( zipArchiveEntry, createInputStreamSupplier(
                              payload ) ) );
metaInfDir.addArchiveEntry( createZipArchiveEntryRequest( zipArchiveEntry,
                             createInputStreamSupplier( payload ) ) );
manifest.addArchiveEntry( createZipArchiveEntryRequest( zipArchiveEntry,
                            createInputStreamSupplier( payload ) ) );

代码示例来源：origin: com.impetus.fabric/fabric-jdbc-driver-shaded

throw new IllegalArgumentException("Method must be set on zipArchiveEntry: " + zipArchiveEntry);
final ZipArchiveEntryRequest zipArchiveEntryRequest = createZipArchiveEntryRequest(zipArchiveEntry, source);
return new Callable<Object>() {
  @Override

代码示例来源：origin: IQSS/dataverse

public void addEntry(ZipArchiveEntry zipArchiveEntry, InputStreamSupplier streamSupplier) throws IOException {
  if (zipArchiveEntry.isDirectory() && !zipArchiveEntry.isUnixSymlink())
    dirs.addArchiveEntry(ZipArchiveEntryRequest.createZipArchiveEntryRequest(zipArchiveEntry, streamSupplier));
  else
    scatterZipCreator.addArchiveEntry(zipArchiveEntry, streamSupplier);
}